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