创建flink的yarn session集群
yarn-session.sh -n 3 -s 3 -nm flink-sessiontest -d -q
-n,–container :在yarn中启动container的个数,实质就是TaskManager的个数
-s,–slots :每个TaskManager管理的Slot个数
-nm,–name :给当前的yarn-session(Flink集群)起一个名字
-d,–detached:后台独立模式启动,守护进程
-tm,–taskManagerMemory :TaskManager的内存大小 单位:MB
-jm,–jobManagerMemory :JobManager的内
flink run -c com.stream.Test -yid application_1608200066135_0002
~/StudyFlink.jar “参数1” "参数2"
一定要注意,给main方法传入参数的时候,将jar包的位置和参数必须写在所有命令的最后面,否则会报错
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。