Flink yarn-application怪异显示： run-application -t yarn-application insert-into_default_catalog.default_database.XXX
ID:00000000000000000000000000000000
搞技术难，坚持把一件事做好难，能坚持写文章记录踩坑生活更是难上加难，如果去定义一个好的文章标题那就是难得不得了了。今天文章标题就这么起了，就为大家能够更好的搜索到（PS:现在搜索一个技术文档实在是太难了，每一个平台都是商业广告化，搜索到一堆垃圾文档），解决你心中的疑惑！
问题展现（先把问题贴出）看到下图，想必你也会口吐芬芳，我去！这不就是和我一样的问题吗！太好啦！
（要的就是这效果，希望下文能解决你心中疑惑），来上才艺！！！
仔细看下，是否和你的相似，相信大家的长得和我的应该都差不多
这里便于大家学习参考，把官网文档粘一下：https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/resource-providers/yarn/
这里给的1.14版本
官网也是写的很简单，需要自己去深究：
我的提交命令：（我们进行了平台封装，写在脚本里）
关键的一小部分进行粘贴：
if [ "$run_mode" = "streaming" ];then
if [[ -z $yjm || -z $ytm ]];then
$BIN_DIR/flink-rt_test.sh run-application -t yarn-application
-d
-Djobmanager.memory.process.size=1024m
-Dtaskmanager.memory.process.size=2048m
......
后面还有很多参数，截个图展现一下：
使用Yarn Application模式启动Flink任务：
这个模式是从 1.11.1开始支持的，具体说明可以参考这个文档，写的还是不错的：https://www.jianshu.com/p/90d9f1f24937
这是因为Flink的配置文件conf/flink-conf.yaml里配置了高可用，但目前Flink HA下Application模式任务的Recovery比较复杂,不支持多个Job所以暂时就把JobId设置成0了。
这个Bug不影响Flink任务的正常运行，如果想要JobId恢复正常，可以暂时关闭Flink HA，等后续官方支持完备之后再升级版本开启。
高可用的配置：https://blog.csdn.net/weixin_33909059/article/details/87993510 [可参考别人的，我就不做赘述了]
配置：
看到这里，你大概知道什么原因和怎么做了吧！实操吧，少年！！！
加油，少年！ 别把自己看成废物，你若肯奋斗，十年后你就是人物。别总抱怨自己一无所有，你若能知足，时时刻刻都是幸福。
