Github user zhangminglei commented on a diff in the pull request: https://github.com/apache/flink/pull/6087#discussion_r192736907 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java --- @@ -406,6 +407,43 @@ public void onError(Throwable error) { onFatalError(error); } + @Override + public void onContainerStarted(ContainerId containerId, Map<String, ByteBuffer> allServiceResponse) { + log.info("The container {} started.", containerId); + } + + @Override + public void onContainerStatusReceived(ContainerId containerId, ContainerStatus containerStatus) { + } + + @Override + public void onContainerStopped(ContainerId containerId) { + log.info("The container {} is stopped.", containerId); + } + + @Override + public void onStartContainerError(ContainerId containerId, Throwable t) { + log.error("Could not start TaskManager in container {}.", containerId, t); + + // release the failed container + YarnWorkerNode yarnWorkerNode = workerNodeMap.remove(new ResourceID(containerId.toString())); --- End diff -- Will change.
---