all我正在开发一个 Yarn 应用程序,该应用程序最近请求在特定节点上分配容器。我像这样编写代码:
String[] nodes = {…};
ContainerRequest request = new ContainerRequest(capability, nodes, null, priority, false, null);
我已经将Relax_Locality设置为 false,并将 yarn.scheduler.capacity.node-locality-delay 设置为 -1,但我仍然无法获得我要求的特定容器。有人可以帮助我吗?非常感谢!
这是 YARN
中的一个未解决的问题(检查 YARN-1412)