flink 7-提交任务

提交方式

一般都是提交到yarn上,当然单机也是可以跑的,而且单机不用安装flink和hadoop

第一种提交到yarn的方法

提交到yarn-cluster

flink -m yarn-cluster -c className -j *.jar -d > log.log 2>&1 &
第二种提交到yarn的方法

先启一个yarn-session,在yarn上开辟一块资源,这时会生成一个yid,然后向这个资源池里提交任务

yarn-session.sh -n 9 -tm 1024 -s 4 -nm Name -d

然后向这个yid中提交job

flink run -c className -j *.jar -yid application_id -d > log.log 2>&1 &
两种提交yarn的区别

个人理解第一种方法各种配置比较个性化,第二种可以在yarn上开辟资源,往session中提交多个job


本文来自互联网用户投稿,文章观点仅代表作者本人,不代表本站立场,不承担相关法律责任。如若转载,请注明出处。 如若内容造成侵权/违法违规/事实不符,请点击【内容举报】进行投诉反馈!

相关文章

立即
投稿

微信公众账号

微信扫一扫加关注

返回
顶部