Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5436
---
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5436#discussion_r168197381
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java ---
@@ -325,26 +325,43 @@ public void
onContainersCompleted(List list
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5436#discussion_r168196542
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java ---
@@ -325,26 +325,43 @@ public void
onContainersCompleted(List list
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5436#discussion_r168185682
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java ---
@@ -325,26 +325,43 @@ public void
onContainersCompleted(List list) {
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5436#discussion_r168184923
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java ---
@@ -325,26 +325,43 @@ public void
onContainersCompleted(List list) {
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/5436
[FLINK-8613] [flip6] [yarn] Return excess containers
## What is the purpose of the change
Upon notification of newly allocated containers, the YarnResourceManager
will only accept a