情况
我们新建maven项目打成jar包后在flink集群中运行,但是报错Caused by: java.lang.ClassNotFoundException
具体报错如下:
java.lang.RuntimeException: Could not look up the main(String[]) method from the class task.MongoDBSourceOrderETL: com/ververica/cdc/debezium/DebeziumDeserializationSchema
at org.apache.flink.client.program.PackagedProgram.hasMainMethod(PackagedProgram.java:309)
at org.apache.flink.client.program.PackagedProgram.<init>(PackagedProgram.java:160)
at org.apache.flink.client.program.PackagedProgram.<init>(PackagedProgram.java:64)
at org.apache.flink.client.program.PackagedProgram$Builder.build(PackagedProgram.java:685)
at org.apache.flink.client.cli.CliFrontend.buildProgram(CliFrontend.java:851)
at org.apache.flink.client.cli.CliFrontend.getPackagedProgram(CliFrontend.java:271)
at org.apache.flink.client.cli.CliFrontend.run(CliFrontend.java:245)
at org.apache.flink.client.cli.CliFrontend.parseAndRun(CliFrontend.java:1
|