写了一个flink kafka到mysql流程,启动一直报错

圣威 发布于 2020/09/01 19:10
阅读 761
收藏 0

软件工程师和算法工程师速来!正在直播:如何使用英特尔oneAPI工具实现PyTorch 优化>>>

写了一个flink kafka到mysql流程,启动一直报错

"C:\Program Files\Java\jdk1.8.0_181\bin\java.exe" "-javaagent:C:\Program Files\JetBrains\IntelliJ IDEA 2018.2.3\lib\idea_rt.jar=54595:C:\Program Files\JetBrains\IntelliJ IDEA 2018.2.3\bin" -Dfile.encoding=UTF-8 -classpath "C:\Program Files\Java\jdk1.8.0_181\jre\lib\charsets.jar;C:\Program Files\Java\jdk1.8.0_181\jre\lib\deploy.jar;C:\Program Files\Java\jdk1.8.0_181\jre\lib\ext\access-bridge-64.jar;C:\Program Files\Java\jdk1.8.0_181\jre\lib\ext\cldrdata.jar;C:\Program Files\Java\jdk1.8.0_181\jre\lib\ext\dnsns.jar;C:\Program Files\Java\jdk1.8.0_181\jre\lib\ext\jaccess.jar;C:\Program Files\Java\jdk1.8.0_181\jre\lib\ext\jfxrt.jar;C:\Program Files\Java\jdk1.8.0_181\jre\lib\ext\localedata.jar;C:\Program Files\Java\jdk1.8.0_181\jre\lib\ext\nashorn.jar;C:\Program Files\Java\jdk1.8.0_181\jre\lib\ext\sunec.jar;C:\Program Files\Java\jdk1.8.0_181\jre\lib\ext\sunjce_provider.jar;C:\Program Files\Java\jdk1.8.0_181\jre\lib\ext\sunmscapi.jar;C:\Program Files\Java\jdk1.8.0_181\jre\lib\ext\sunpkcs11.jar;C:\Program Files\Java\jdk1.8.0_181\jre\lib\ext\zipfs.jar;C:\Program Files\Java\jdk1.8.0_181\jre\lib\javaws.jar;C:\Program Files\Java\jdk1.8.0_181\jre\lib\jce.jar;C:\Program Files\Java\jdk1.8.0_181\jre\lib\jfr.jar;C:\Program Files\Java\jdk1.8.0_181\jre\lib\jfxswt.jar;C:\Program Files\Java\jdk1.8.0_181\jre\lib\jsse.jar;C:\Program Files\Java\jdk1.8.0_181\jre\lib\management-agent.jar;C:\Program Files\Java\jdk1.8.0_181\jre\lib\plugin.jar;C:\Program Files\Java\jdk1.8.0_181\jre\lib\resources.jar;C:\Program Files\Java\jdk1.8.0_181\jre\lib\rt.jar;D:\flink\target\classes;D:\repo\org\apache\flink\flink-core\1.11.1\flink-core-1.11.1.jar;D:\repo\org\apache\flink\flink-annotations\1.11.1\flink-annotations-1.11.1.jar;D:\repo\org\apache\flink\flink-metrics-core\1.11.1\flink-metrics-core-1.11.1.jar;D:\repo\org\apache\flink\flink-shaded-asm-7\7.1-11.0\flink-shaded-asm-7-7.1-11.0.jar;D:\repo\org\apache\commons\commons-lang3\3.3.2\commons-lang3-3.3.2.jar;D:\repo\com\esotericsoftware\kryo\kryo\2.24.0\kryo-2.24.0.jar;D:\repo\com\esotericsoftware\minlog\minlog\1.2\minlog-1.2.jar;D:\repo\org\objenesis\objenesis\2.1\objenesis-2.1.jar;D:\repo\commons-collections\commons-collections\3.2.2\commons-collections-3.2.2.jar;D:\repo\org\apache\commons\commons-compress\1.20\commons-compress-1.20.jar;D:\repo\org\apache\flink\flink-shaded-guava\18.0-11.0\flink-shaded-guava-18.0-11.0.jar;D:\repo\org\slf4j\slf4j-api\1.7.15\slf4j-api-1.7.15.jar;D:\repo\com\google\code\findbugs\jsr305\1.3.9\jsr305-1.3.9.jar;D:\repo\org\apache\flink\force-shading\1.11.1\force-shading-1.11.1.jar;D:\repo\org\apache\flink\flink-table-api-scala_2.11\1.11.1\flink-table-api-scala_2.11-1.11.1.jar;D:\repo\org\scala-lang\scala-reflect\2.11.12\scala-reflect-2.11.12.jar;D:\repo\org\scala-lang\scala-library\2.11.12\scala-library-2.11.12.jar;D:\repo\org\scala-lang\scala-compiler\2.11.12\scala-compiler-2.11.12.jar;D:\repo\org\scala-lang\modules\scala-xml_2.11\1.0.5\scala-xml_2.11-1.0.5.jar;D:\repo\org\scala-lang\modules\scala-parser-combinators_2.11\1.0.4\scala-parser-combinators_2.11-1.0.4.jar;D:\repo\org\apache\flink\flink-table-api-scala-bridge_2.11\1.11.1\flink-table-api-scala-bridge_2.11-1.11.1.jar;D:\repo\org\apache\flink\flink-scala_2.11\1.11.1\flink-scala_2.11-1.11.1.jar;D:\repo\org\apache\flink\flink-streaming-scala_2.11\1.11.1\flink-streaming-scala_2.11-1.11.1.jar;D:\repo\org\apache\flink\flink-table-runtime-blink_2.11\1.11.1\flink-table-runtime-blink_2.11-1.11.1.jar;D:\repo\org\codehaus\janino\janino\3.0.9\janino-3.0.9.jar;D:\repo\org\codehaus\janino\commons-compiler\3.0.9\commons-compiler-3.0.9.jar;D:\repo\org\apache\calcite\avatica\avatica-core\1.16.0\avatica-core-1.16.0.jar;D:\repo\org\reflections\reflections\0.9.10\reflections-0.9.10.jar;D:\repo\org\javassist\javassist\3.19.0-GA\javassist-3.19.0-GA.jar;D:\repo\org\apache\flink\flink-table-common\1.11.1\flink-table-common-1.11.1.jar;D:\repo\org\apache\flink\flink-java\1.11.1\flink-java-1.11.1.jar;D:\repo\org\apache\commons\commons-math3\3.5\commons-math3-3.5.jar;D:\repo\org\apache\flink\flink-streaming-java_2.11\1.11.1\flink-streaming-java_2.11-1.11.1.jar;D:\repo\org\apache\flink\flink-runtime_2.11\1.11.1\flink-runtime_2.11-1.11.1.jar;D:\repo\org\apache\flink\flink-queryable-state-client-java\1.11.1\flink-queryable-state-client-java-1.11.1.jar;D:\repo\org\apache\flink\flink-hadoop-fs\1.11.1\flink-hadoop-fs-1.11.1.jar;D:\repo\commons-io\commons-io\2.4\commons-io-2.4.jar;D:\repo\org\apache\flink\flink-shaded-netty\4.1.39.Final-11.0\flink-shaded-netty-4.1.39.Final-11.0.jar;D:\repo\org\apache\flink\flink-shaded-jackson\2.10.1-11.0\flink-shaded-jackson-2.10.1-11.0.jar;D:\repo\org\apache\flink\flink-shaded-zookeeper-3\3.4.14-11.0\flink-shaded-zookeeper-3-3.4.14-11.0.jar;D:\repo\com\typesafe\akka\akka-actor_2.11\2.5.21\akka-actor_2.11-2.5.21.jar;D:\repo\com\typesafe\config\1.3.3\config-1.3.3.jar;D:\repo\org\scala-lang\modules\scala-java8-compat_2.11\0.7.0\scala-java8-compat_2.11-0.7.0.jar;D:\repo\com\typesafe\akka\akka-stream_2.11\2.5.21\akka-stream_2.11-2.5.21.jar;D:\repo\org\reactivestreams\reactive-streams\1.0.2\reactive-streams-1.0.2.jar;D:\repo\com\typesafe\ssl-config-core_2.11\0.3.7\ssl-config-core_2.11-0.3.7.jar;D:\repo\com\typesafe\akka\akka-protobuf_2.11\2.5.21\akka-protobuf_2.11-2.5.21.jar;D:\repo\com\typesafe\akka\akka-slf4j_2.11\2.5.21\akka-slf4j_2.11-2.5.21.jar;D:\repo\org\clapper\grizzled-slf4j_2.11\1.3.2\grizzled-slf4j_2.11-1.3.2.jar;D:\repo\com\github\scopt\scopt_2.11\3.5.0\scopt_2.11-3.5.0.jar;D:\repo\org\xerial\snappy\snappy-java\1.1.4\snappy-java-1.1.4.jar;D:\repo\com\twitter\chill_2.11\0.7.6\chill_2.11-0.7.6.jar;D:\repo\com\twitter\chill-java\0.7.6\chill-java-0.7.6.jar;D:\repo\org\lz4\lz4-java\1.6.0\lz4-java-1.6.0.jar;D:\repo\org\apache\flink\flink-clients_2.11\1.11.1\flink-clients_2.11-1.11.1.jar;D:\repo\org\apache\flink\flink-optimizer_2.11\1.11.1\flink-optimizer_2.11-1.11.1.jar;D:\repo\commons-cli\commons-cli\1.3.1\commons-cli-1.3.1.jar;D:\repo\org\projectlombok\lombok\1.18.4\lombok-1.18.4.jar;D:\repo\org\apache\flink\flink-connector-kafka-0.10_2.11\1.11.1\flink-connector-kafka-0.10_2.11-1.11.1.jar;D:\repo\org\apache\flink\flink-connector-kafka-base_2.11\1.11.1\flink-connector-kafka-base_2.11-1.11.1.jar;D:\repo\org\apache\kafka\kafka-clients\0.10.2.2\kafka-clients-0.10.2.2.jar;D:\repo\net\jpountz\lz4\lz4\1.3.0\lz4-1.3.0.jar;D:\repo\org\apache\flink\flink-table-api-java\1.11.1\flink-table-api-java-1.11.1.jar;D:\repo\org\apache\flink\flink-table-api-java-bridge_2.11\1.9-SNAPSHOT\flink-table-api-java-bridge_2.11-1.9-20200820.062815-505.jar;D:\repo\com\alibaba\fastjson\1.2.62\fastjson-1.2.62.jar;D:\repo\mysql\mysql-connector-java\5.1.38\mysql-connector-java-5.1.38.jar" flink.FlinkSqlWindowUserPv
SLF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder".
SLF4J: Defaulting to no-operation (NOP) logger implementation
SLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further details.
Exception in thread "main" java.lang.NoSuchMethodError: org.apache.flink.table.catalog.CatalogManager.(Ljava/lang/String;Lorg/apache/flink/table/catalog/Catalog;)V
	at org.apache.flink.table.api.java.internal.StreamTableEnvironmentImpl.create(StreamTableEnvironmentImpl.java:105)
	at org.apache.flink.table.api.java.StreamTableEnvironment.create(StreamTableEnvironment.java:112)
	at flink.FlinkSqlWindowUserPv.main(FlinkSqlWindowUserPv.java:49)

Process finished with exit code 1
加载中
0
yunlongli6
yunlongli6

改天我也来做个实验

0
不会飞的小龙人
不会飞的小龙人

你这是缺jar包吧,把pom.xml贴出来一下

0
codingxyz
codingxyz
<dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-java</artifactId>
    <scope>provide</scope>
</dependency>

本地运行的话 scope 不能为provide

0
圣威

已经解决了,有些包本地没加载到,这一套依赖的包比较多,感谢大家

OSCHINA
登录后可查看更多优质内容
返回顶部
顶部
返回顶部
顶部