flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From trohrm...@apache.org
Subject [1/2] flink git commit: [hotfix] Suppress restarts if rescaling operation fails
Date Wed, 04 Apr 2018 13:51:30 GMT
Repository: flink
Updated Branches:
  refs/heads/release-1.5 c7d0f4768 -> 85af3a286


[hotfix] Suppress restarts if rescaling operation fails


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/85af3a28
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/85af3a28
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/85af3a28

Branch: refs/heads/release-1.5
Commit: 85af3a286472beb24638b835e77a7ce5a739ed19
Parents: 3277b79
Author: Till Rohrmann <trohrmann@apache.org>
Authored: Wed Apr 4 15:47:16 2018 +0200
Committer: Till Rohrmann <trohrmann@apache.org>
Committed: Wed Apr 4 15:51:17 2018 +0200

----------------------------------------------------------------------
 .../java/org/apache/flink/runtime/jobmaster/JobMaster.java    | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/85af3a28/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java
b/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java
index 934c0b2..f5606fb 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java
@@ -41,6 +41,7 @@ import org.apache.flink.runtime.clusterframework.types.AllocationID;
 import org.apache.flink.runtime.clusterframework.types.ResourceID;
 import org.apache.flink.runtime.concurrent.FutureUtils;
 import org.apache.flink.runtime.execution.ExecutionState;
+import org.apache.flink.runtime.execution.SuppressRestartsException;
 import org.apache.flink.runtime.executiongraph.ArchivedExecutionGraph;
 import org.apache.flink.runtime.executiongraph.Execution;
 import org.apache.flink.runtime.executiongraph.ExecutionAttemptID;
@@ -508,7 +509,11 @@ public class JobMaster extends FencedRpcEndpoint<JobMasterId> implements
JobMast
 			(Acknowledge ignored, Throwable throwable) -> {
 				if (throwable != null) {
 					// fail the newly created execution graph
-					newExecutionGraph.failGlobal(new FlinkException("Failed to rescale the job " + jobGraph.getJobID()
+ '.', throwable));
+					newExecutionGraph.failGlobal(
+						new SuppressRestartsException(
+							new FlinkException(
+								String.format("Failed to rescale the job %s.", jobGraph.getJobID()),
+								throwable)));
 				}
 			});
 


Mime
View raw message