请教 yarn-session.sh启动任务指定的应用名和队列无效怎么办？
我有一个hadoop集群和一台机器A.
我在机器A上，使用bin/yarn-session.sh -n 5 -jm 1g -tm 4g -s 4 -qu root.flink -nm fsql-cli > /dev/null 2>&1 &命令，启动了一个yarn-session， 其中，指定了队列root.flink和应用名fsql-cli.
但是，在yarn控制台中看到应用的名称和队列跟指定的名称大多数情况下不一致（多次提交，偶尔一致），如图： https://imgchr.com/i/NJIn4x
应用名为：Flink session cluster 队列名为：root.default
请问为什么我指定的队列名和应用名没有生效？
flink版本：1.10.0 flink-conf.yaml配置： [fsql@10-42-63-116 conf]$ grep -v ^# flink-conf.yaml |grep -v ^$ jobmanager.rpc.address: localhost jobmanager.rpc.port: 6123 jobmanager.heap.size: 1024m taskmanager.memory.process.size: 2048m taskmanager.numberOfTaskSlots: 10 parallelism.default: 1 jobmanager.execution.failover-strategy: region
*来自志愿者整理的flink邮件归档
写回答
-
你可以看一下HDFS上面staging目录($HOME/.flink/application_id)里面有client端生效的flink-conf.yaml 看看里面的"yarn.application.queue"和"yarn.application.name"是不是预期的值。
另外，-n参数很早就不支持了，这样设置也不会起作用的，都是动态申请TM的
*来自志愿者整理的flink邮件归档
2021-12-06 21:20:32赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
