[问题踩坑]Flink 1.11.1 on Yarn Application模式时,JobId始终为00000000000000000000000000000000

Posted 白夜鸦羽

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了[问题踩坑]Flink 1.11.1 on Yarn Application模式时,JobId始终为00000000000000000000000000000000相关的知识,希望对你有一定的参考价值。

使用Yarn Application模式启动Flink任务的命令如下
./bin/flink run-application -t yarn-application hdfs://hadoop-master:9000/shadow/FlinkSQLTest-1.0-SNAPSHOT.jar
当Flink 任务启动后,发现JobId异常始终为00000000000000000000000000000000,而正常的JobId应该为一个随机的字符串


这是因为Flink的配置文件conf/flink-conf.yaml里配置了高可用,但目前Flink HA下Application模式任务的Recovery比较复杂,不支持多个Job所以暂时就把JobId设置成0了。
这个Bug不影响Flink任务的正常运行,如果想要JobId恢复正常,可以暂时关闭Flink HA,等后续官方支持完备之后再升级版本开启。

社区类似问题:flink-1.11 使用 application 模式时 jobid 问题

以上是关于[问题踩坑]Flink 1.11.1 on Yarn Application模式时,JobId始终为00000000000000000000000000000000的主要内容,如果未能解决你的问题,请参考以下文章

[问题踩坑]Flink 1.11.1 SQL View中UDTF调用异常 Column ‘xxx‘ not found in any table

[问题踩坑]Flink 1.11.1 SQL View中UDTF调用异常 Column ‘xxx‘ not found in any table

Flink Java踩坑记录(gegge1.10.0)

Flink Java踩坑记录(gegge1.10.0)

flink报错踩坑:org.apache.flink.table.catalog.hive.client.HiveShimV100.registerTemporaryFunction

阿里巴巴大规模应用Flink的踩坑经验:如何大幅降低 HDFS 压力?