采纳答案成功!
向帮助你的同学说点啥吧!感谢那些助人为乐的人
老师,我搭建和Standalone的HA模式,然后使用到了hadoopjar包。 然后这时候我们运行你flink run就是默认运行在yarn的session模式下了。这时候如何选择运行在Standalone模式下?
关于两种运行方式的相关参数,flink提交作业那个官网文章做了相信的描述的,可以参考下
老师,我的意思是在Standalone模式下运行flink run命令直接可以运行在Standalone集群中,但是加上了hadoop的jar包到lib目录之后,再运行flink run命令就跑到yarn的session模式下运行了。我怎么在Standalone和Yarn模式下切换。
不会的呢,他们各种都可以带jar的呢。每个应用程序不管啥模式都可以带上jar的。官网那个提交作业的你先通读一遍
老师,我的意思是你的讲课顺序是先讲的Standalone模式,你这时候运行flink run的确是运行在Standalone模式下。后面你又搭建了hadoop集群,这时候运行flink run命令就跑到了yarn模式了。我已经试过好几次了。如果没有hadoop环境使用flink run运行的命令就是运行在Standalone模式。如果有了hadoop环境就自动跑到yarn模式上了
不同模式运行方式不同,但是jar是一样的。session方式是有一个sessionid相关的东西。你换个目录执行下试试
登录后可查看更多问答,登录/注册
入行或转型大数据新姿势,多语言系统化讲解,极速入门Flink
935 18
1.0k 15
1.4k 14
1.3k 13
1.6k 13