Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5675
---
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5675#discussion_r175020997
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java ---
@@ -325,67 +328,74 @@ public float getProgress() {
@Override
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5675#discussion_r175020983
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java ---
@@ -395,10 +405,13 @@ public void onNodesUpdated(List list) {
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5675#discussion_r174834515
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java ---
@@ -325,67 +328,74 @@ public float getProgress() {
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5675#discussion_r174834772
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java ---
@@ -395,10 +405,13 @@ public void onNodesUpdated(List list) {
GitHub user GJL opened a pull request:
https://github.com/apache/flink/pull/5675
[FLINK-7804][flip6] YarnResourceManager does not execute AMRMClientAsync
callbacks in main thread
## What is the purpose of the change
*The `YarnResourceManager` registers callbacks at a
