我正在开发一个yarn应用程序,它最近请求在特定节点上分配容器。我这样写代码:
String[] nodes = {…};
ContainerRequest request = new ContainerRequest(capability, nodes, null, priority, false, null);
我已经将relax\u locality设置为false,并将yarn.scheduler.capacity.node-locality-delay设置为-1,但仍然无法获得我请求的特定容器。有人能帮我吗?非常感谢!
1条答案
按热度按时间mnowg1ta1#
这是Yarn中的一个公开问题(检查Yarn-1412)