You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by uc...@apache.org on 2016/11/30 15:18:29 UTC
flink git commit: [FLINK-5123] [task] Add missing @Override to
Task#failExternally
Repository: flink
Updated Branches:
refs/heads/master ac7d87158 -> 8cdb406dc
[FLINK-5123] [task] Add missing @Override to Task#failExternally
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8cdb406d
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/8cdb406d
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/8cdb406d
Branch: refs/heads/master
Commit: 8cdb406dc9d53e2864fc0daa7e5b4149acdb9308
Parents: ac7d871
Author: Ufuk Celebi <uc...@apache.org>
Authored: Wed Nov 30 16:18:03 2016 +0100
Committer: Ufuk Celebi <uc...@apache.org>
Committed: Wed Nov 30 16:18:12 2016 +0100
----------------------------------------------------------------------
.../main/java/org/apache/flink/runtime/taskmanager/Task.java | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/8cdb406d/flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java b/flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java
index c794f56..bd8c196 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java
@@ -24,15 +24,15 @@ import org.apache.flink.api.common.JobID;
import org.apache.flink.api.common.TaskInfo;
import org.apache.flink.api.common.cache.DistributedCache;
import org.apache.flink.configuration.Configuration;
-import org.apache.flink.core.fs.FileSystem;
import org.apache.flink.configuration.TaskManagerOptions;
+import org.apache.flink.core.fs.FileSystem;
import org.apache.flink.core.fs.Path;
import org.apache.flink.runtime.accumulators.AccumulatorRegistry;
import org.apache.flink.runtime.blob.BlobKey;
import org.apache.flink.runtime.broadcast.BroadcastVariableManager;
+import org.apache.flink.runtime.checkpoint.CheckpointMetaData;
import org.apache.flink.runtime.checkpoint.decline.CheckpointDeclineTaskNotCheckpointingException;
import org.apache.flink.runtime.checkpoint.decline.CheckpointDeclineTaskNotReadyException;
-import org.apache.flink.runtime.checkpoint.CheckpointMetaData;
import org.apache.flink.runtime.concurrent.BiFunction;
import org.apache.flink.runtime.deployment.InputGateDeploymentDescriptor;
import org.apache.flink.runtime.deployment.ResultPartitionDeploymentDescriptor;
@@ -901,6 +901,7 @@ public class Task implements Runnable, TaskActions {
*
* <p>This method never blocks.</p>
*/
+ @Override
public void failExternally(Throwable cause) {
LOG.info("Attempting to fail task externally " + taskNameWithSubtask);
cancelOrFailAndCancelInvokable(ExecutionState.FAILED, cause);