一:参数
flink 模式 – standalone
二:步骤
1. 将本地测试好的代码进行本地运行。确保没问题,进行打包。
2. 找到打好的jar包,将jar包上传到对应的服务器。
3. 执行flink命令,跑代码。
/opt/flink/flink-1.13.6/bin/flink run -c com.shds.platform.eventlog.DetectAndDefenseEventLogNormal ./shds-platform-eventlog-1.0-SNAPSHOT.jar
备注:
- -c 填写存在main的类名。
- 查看包中是否有对应的主类名。
jar tf shds-platform-eventlog-1.0-SNAPSHOT.jar | grep com.shds.platform.eventlog.DetectAndDefenseEventLogNormal
文章来源:https://www.toymoban.com/news/detail-761838.html
4. 遇到的问题。
- 主类,没有写全。
DetectAndDefenseEventLogNormal 这个虽然是主类,但是必须写全名,加上包名。 - 提交到flink上,有报错。
https://www.google.com/search?q=cannot+assign+instance+of+org.apache.commons.collections.map.linkedmap+to+field+org.apache.flink.streaming.connectors.kafka.flinkkafkaconsumerbase.pendingoffsetstocommit+of+type+org.apache.commons.collections.map.linkedmap+in+instance+of+org.apache.flink.streaming.connectors.kafka.flinkkafkaconsumer&oq=&gs_lcrp=EgZjaHJvbWUqCQgAECMYJxjqAjIJCAAQIxgnGOoCMgkIARAjGCcY6gIyCQgCECMYJxjqAjIJCAMQIxgnGOoCMgkIBBAjGCcY6gIyCQgFEEUYOxjCAzIJCAYQRRg7GMIDMgkIBxBFGDsYwgPSAQsxMDYzMzE5ajBqN6gCCLACAQ&sourceid=chrome&ie=UTF-8
文章来源地址https://www.toymoban.com/news/detail-761838.html
classloader.resolve-order: parent-first
到了这里,关于工作实践篇 Flink(一:flink提交jar)的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!