【Flink-1.14】三种启动模式

一、准备

环境变量中添加

export HADOOP_CLASSPATH=`hadoop classpath`

TopSpeedWindowing.jar 同步到 lib/下

二、不同模式命令

Application Mode

flink run-application -t yarn-application ./examples/streaming/TopSpeedWindowing.jar

Per-Job Mode

flink run -t yarn-per-job --detached ./examples/streaming/TopSpeedWindowing.jar

Session Mode

flink run -t yarn-session \
  -Dyarn.application.id=application_XXXX_YY \
  ./examples/streaming/TopSpeedWindowing.jar