嗨,我这边在使用flink1.12.2提交yarn-application的任务时发现一个问题,
提交任务的flink官网的例子为
./bin/flink run-application -t yarn-application
./examples/streaming/TopSpeedWindowing.jar

如果其中有部分写错的话 yarn-application 写成了 yarn-appliation的话
就会报错
[image: image.png]
这里我看了代码是CliFrontend 封装的 213行的配置集合 effectiveConfiguration
有问题,导致DefaultClusterClientServiceLoader.java:83 判断进入报错
[image: image.png]
我觉得这里的报错信息的描述有问题 会造成误导,是使用者误认为是自己的HADOOP_CLASSPATH 环境有问题,希望可以得到大家的回复

Reply via email to