yarn 上的 Flink 1.12.0 无法识别 yn
Flink 1.12.0 on yarn doesn't recognize yn
我使用以下脚本在 yarn 上提交我的申请。
MAIN_CLASS=org.example.app.HelloFlink
flink run -m yarn-cluster -yn 4 -ys 1 -ynm FlinkHiveIntegrationTest -c $MAIN_CLASS /learn.flink.ioc-1.0-SNAPSHOT.jar
它抱怨 Could not get job jar and dependencies from JAR file: JAR file does not exist: -yn。
当我删除脚本中的 -yn 4 时，它就可以工作了。我在之前的 flink 版本中使用 -yn 来指定容器的数量。那么，如何指定 Flink 1.12.0
的容器数量呢？
-yn 选项已被 FLIP-6 弃用，并且自 Flink 1.8 中删除遗留运行时以来已被忽略。现在 CLI 不再识别此选项；参见 FLINK-12362。
相反，ResourceManager 将根据需要自动启动尽可能多的容器以满足作业请求的并行性。
我使用以下脚本在 yarn 上提交我的申请。
MAIN_CLASS=org.example.app.HelloFlink
flink run -m yarn-cluster -yn 4 -ys 1 -ynm FlinkHiveIntegrationTest -c $MAIN_CLASS /learn.flink.ioc-1.0-SNAPSHOT.jar
它抱怨 Could not get job jar and dependencies from JAR file: JAR file does not exist: -yn。
当我删除脚本中的 -yn 4 时，它就可以工作了。我在之前的 flink 版本中使用 -yn 来指定容器的数量。那么，如何指定 Flink 1.12.0
-yn 选项已被 FLIP-6 弃用，并且自 Flink 1.8 中删除遗留运行时以来已被忽略。现在 CLI 不再识别此选项；参见 FLINK-12362。
相反，ResourceManager 将根据需要自动启动尽可能多的容器以满足作业请求的并行性。