未验证 提交 c9ad0a07 编写于 作者: S sihuazhou 提交者: Till Rohrmann

[FLINK-9619] Eagerly close the connection with task manager when the container is completed.

This closes #6185.
上级 134e0444
......@@ -336,8 +336,9 @@ public class YarnResourceManager extends ResourceManager<YarnWorkerNode> impleme
// Container completed unexpectedly ~> start a new one
final Container container = yarnWorkerNode.getContainer();
internalRequestYarnContainer(container.getResource(), yarnWorkerNode.getContainer().getPriority());
closeTaskManagerConnection(resourceId, new Exception(containerStatus.getDiagnostics()));
}
// Eagerly close the connection with task manager.
closeTaskManagerConnection(resourceId, new Exception(containerStatus.getDiagnostics()));
}
}
);
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册