Github user zhangminglei commented on a diff in the pull request:
https://github.com/apache/flink/pull/6087#discussion_r192728317
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java ---
@@ -356,7 +363,8 @@ public void onContainersAllocated(List<Container>
containers) {
final String containerIdStr =
container.getId().toString();
final ResourceID resourceId = new
ResourceID(containerIdStr);
-
+ this.resourceId = resourceId;
+ this.container = container;
--- End diff --
Yes. Thanks, I know what is wrong with my code.Will change.
---