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<NodeReport> list) {
@Override
public void onError(Throwable error) {
- onFatalError(error);
+ runAsync(() -> onFatalError(error));
--- End diff --
I think it would be good to let the error propagate directly. In case of an
OOM exception we want to quickly shut down the JVM.
---
