flink1.12.0提交脚本说明

Posted 2022-12-10 上官沐雪

flink提交脚本

以下是flink的提交脚本

flink run \\
-m yarn-cluster \\
-yjm 1024 \\
-ytm 1024 \\
-s hdfs:///flink/flink-checkpoints/28b9aef62561ff6ef00dadbd12625d30/chk-1477665 \\
-c com.zhendao.task.ZhenTuiBaoTask \\
-yqu root.streaming \\
-ynm Flink-ZhenTuiBaoTask \\
/var/lib/hadoop-hdfs/bin/flink-pro/zhen-tuibao-realtime-1.0-SNAPSHOT.jar 

注释：

-m 运行模式
-yjm 1024 jobmanager使用的内存
-ytm 1024 taskmaneger使用的内存
-s savapoint的地址
-c class主类的地址
-yqu yarn的队列
-ynm 提交到yarn上程序的名字
/var/lib/hadoop-hdfs/bin/flink-pro/zhen-tuibao-realtime-1.0-SNAPSHOT.jar 相应的jiar包