我正在尝试通过使用 YarnClient
. 我在根查询下有默认查询(默认设置)。
此示例:
yarn
.getAllQueues() //get all queries (size == 1)
.stream()
.findFirst()
.get()
.getQueueName() //get the name of the only query == default
将导致 "default"
,那么
yarn
.getAllQueues()
.stream()
.findFirst()
.get()
.getApplications()
将导致空列表,但是
yarn
.getQueueInfo( //returns Queue info searched by name which is default in this case
yarn
.getAllQueues() //returns all queues
.stream()
.findFirst() //find first and only queue which is default
.get()
.getQueueName()) //get it's name which is String "default"
.getApplications() //returns all applications as a list of size one
将给我一个size==1的列表(我正在集群中运行一个Yarn应用程序)
我的纱团是在版本 2.8.0
,我尝试使用Yarn二进制文件
YarnClient 2.7.1
, 2.8.0
, 2.8.1
我是做错了什么,还是只是在api中保留了很长时间的bug?
暂无答案!
目前还没有任何答案,快来回答吧!