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 <u...@apache.org> Authored: Wed Nov 30 16:18:03 2016 +0100 Committer: Ufuk Celebi <u...@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);