You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by mx...@apache.org on 2015/10/19 12:07:18 UTC
flink git commit: [FLINK-2611][yarn] do not fail application in
shutdown hook
Repository: flink
Updated Branches:
refs/heads/master d6567a00f -> da071bc70
[FLINK-2611][yarn] do not fail application in shutdown hook
The application status is set to failed for jobs which did not complete
successfully. If the client shuts down the YARN cluster, the
applications should be reported as SUCCESSFUL.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/da071bc7
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/da071bc7
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/da071bc7
Branch: refs/heads/master
Commit: da071bc70f80510ae688565cc24f8edb55984e1d
Parents: d6567a0
Author: Maximilian Michels <mx...@apache.org>
Authored: Mon Oct 19 11:57:47 2015 +0200
Committer: Maximilian Michels <mx...@apache.org>
Committed: Mon Oct 19 12:06:34 2015 +0200
----------------------------------------------------------------------
.../src/main/java/org/apache/flink/yarn/FlinkYarnCluster.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/da071bc7/flink-yarn/src/main/java/org/apache/flink/yarn/FlinkYarnCluster.java
----------------------------------------------------------------------
diff --git a/flink-yarn/src/main/java/org/apache/flink/yarn/FlinkYarnCluster.java b/flink-yarn/src/main/java/org/apache/flink/yarn/FlinkYarnCluster.java
index 989ae0f..a494f65 100644
--- a/flink-yarn/src/main/java/org/apache/flink/yarn/FlinkYarnCluster.java
+++ b/flink-yarn/src/main/java/org/apache/flink/yarn/FlinkYarnCluster.java
@@ -496,7 +496,7 @@ public class FlinkYarnCluster extends AbstractFlinkYarnCluster {
@Override
public void run() {
LOG.info("Shutting down FlinkYarnCluster from the client shutdown hook");
- shutdown(true);
+ shutdown(false);
}
}