flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "wangweiguang@stevegame.cn" <wangweigu...@stevegame.cn>
Subject Flink 1.10读取kafka数据,打包jar,提交任务到集群运行测试,遇到java.lang.NoClassDefFoundError: org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase问题,求救大神帮忙解答,谢谢!
Date Mon, 13 Apr 2020 06:31:19 GMT

你好:

    我在用Flink 1.10读取kafka数据,本地IDEA环境执行没有问题,将代码编译打包(不是fat
jar)到集群上运行测试,执行提示:java.lang.NoClassDefFoundError: org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase问题。
    我在Flink 1.10集群的每个节点下的 /lib下都添加了kafka依赖包:flink-connector-kafka_2.11-1.10.0.jar
    我启动的命令:
    我先启动了一个Yarn session:
    yarn-session.sh -yd -jm 2048m -tm 2048m -s 10
    然后在session提交任务测试
    flink run -d -p 2 -m yarn-cluster -c com.sdf.flink.streaming.BroadcastOrderJoinGoodsName
-yid application_1585277813790_0006 ./flink-project_1.10.0-1.0.jar
    启动就报如下错误:
   

/lib下的依赖包:

代码片段:

就是简单的读取数据,输出测试!



                                                                                  






史蒂夫软件(深圳)有限公司
技术部   王卫光
wangweiguang@stevegame.cn 
地址/Add:深圳南山科区科技园高新南十二道康佳研发大厦A座
手机/Mob:13128970998
http://www.stevengame.com/
Mime
  • Unnamed multipart/related (inline, None, 0 bytes)
View raw message