flink1.13安装配置
flink on yarn三种部署模式启动命令
per job
# flink旧版本
./bin/flink run -m yarn-cluster -yjm 1024 -ytm 1024 -yqu root.up ./examples/streaming/TopSpeedWindowing.jar
./examples/batch/WordCount.jar \
-input hdfs://mycluster/tmp/input/ \
-output hdfs://mycluster/tmp/output2
# flink1.13
./bin/flink run -t yarn-per-job -d \
-Djobmanager.memory.process.size=1024m \
-Dtaskmanager.memory.process.size=1024m \
-Dtaskmanager.numberOfTaskSlots=1 \
-Dparallelism.default=1 \
-Dyarn.application.name="MyFlinkApp" \
-Dyarn.application.queue=myQueue ./examples/streaming/TopSpeedWindowing.jar
session
# 启动
./bin/yarn-session.sh --detached -Dyarn.application.queue root.xxx
# 执行任务
./bin/flink run -t yarn-session \
-Dyarn.application.id=application_XXXX_YY \
./examples/streaming/TopSpeedWindowing.jar
# close
echo "stop" | ./bin/yarn-session.sh -id application_1632098537301_0003
application-mode
bin/flink run-application -t yarn-application \
-Djobmanager.memory.process.size=1024m \
-Dtaskmanager.memory.process.size=1024m \
-Dtaskmanager.numberOfTaskSlots=1 \
-Dparallelism.default=1 \
-Dyarn.application.name="MyFlinkApp" \
-Dyarn.application.queue=myQueue ./examples/streaming/TopSpeedWindowing.jar
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。