??????Flink 1.10????kafka??????????jar??????????????????????????????java.lang.NoClassDefFoundError: org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase??????????????????????????????

Sun, 12 Apr 2020 23:34:45 -0700 

????????????flink-connector-elasticsearch-base_2.11-1.10.0.jar



------------------ ???????? ------------------
??????: "[email protected]"<[email protected]&gt;; 
????????: 2020??4??13??(??????) ????2:31
??????: "user-zh"<[email protected]&gt;; 
????: Flink 
1.10????kafka??????????jar??????????????????????????????java.lang.NoClassDefFoundError:
 
org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase??????????????????????????????





??????


&nbsp; &nbsp; ??????Flink 
1.10????kafka??????????IDEA??????????????????????????????????????fat 
jar??????????????????????????????java.lang.NoClassDefFoundError: 
org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase??????
&nbsp; &nbsp; ????Flink 1.10?????????????????? 
/lib??????????kafka????????flink-connector-kafka_2.11-1.10.0.jar
&nbsp; &nbsp; ??????????????
&nbsp; &nbsp; ??????????????Yarn session:
&nbsp; &nbsp; yarn-session.sh -yd -jm 2048m -tm 2048m -s 10
&nbsp; &nbsp; ??????session????????????
&nbsp; &nbsp; 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
&nbsp; &nbsp; ??????????????????
&nbsp; &nbsp;


/lib????????????



??????????

 

??????????????????????????????



 &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; 
&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; 
&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; 
&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; 













??????????????????????????
?????? &nbsp; ??????
[email protected]&nbsp;
????/Add????????????????????????????????????????????A??
????/Mob??13128970998
http://www.stevengame.com/

回复