你可以看一下HDFS上面staging目录($HOME/.flink/application_id)里面有client端生效的*flink-conf.yaml* 看看里面的"yarn.application.queue"和"yarn.application.name"是不是预期的值。
另外,-n参数很早就不支持了,这样设置也不会起作用的,都是动态申请TM的 Best, Yang MuChen <[email protected]> 于2020年6月22日周一 下午7:32写道: > hi,all: > > > 我有一个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
