如何解决在Flink中使用作业模式和分离模式提交应用程序
我使用以下命令将流应用程序提交到纱线。 flink run
命令将启动Java进程CliFrontend
。
flink run -d -m yarn-cluster -yqu Queue1 -yn 6 -ynm MyFlinkApp -c my.CheckpointTest ./flink.kafka.exploration-1.0-jar-with-dependencies.jar
以上命令使用分离模式提交应用程序,因此当作业启动时,linux shell终端返回。
然后,我ps -ef|grep java or jps
CliFrontend进程消失了,我发现CliFrontend进程消失了,我认为CliFrontend
进程应该在此流应用程序的整个生命周期中在后台运行。
不确定我是否正确理解。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。