上传了官方的JAVA 示例代码打包后的JAR包,测试的时候提示这个
The Handler 'handleRequest' is not implemented in class 'example.App' 上传了官方的JAVA 示例代码打包后的JAR包,测试的时候提示这个
Flink 1.10读取kafka数据,打包jar,提交任务到集群运行测试,遇到问题
我在用Flink 1.10读取kafka数据,本地IDEA环境执行没有问题,将代码编译打包(不是fat jar)到集群上运行测试,执行提示:java.lang.NoClassDefFoundError: org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase问题。 我在Flink 1.10集群的每个节点下的 /lib下....
本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。