You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2018/01/30 21:55:56 UTC
[2/2] flink git commit: [hotfix] Rearrange TaskExecutor imports
[hotfix] Rearrange TaskExecutor imports
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/23ff1203
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/23ff1203
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/23ff1203
Branch: refs/heads/master
Commit: 23ff1203a0583d2859b3f0f92f4cb0c604b83baa
Parents: 0e20b61
Author: Till Rohrmann <tr...@apache.org>
Authored: Thu Jan 25 12:01:09 2018 +0100
Committer: Till Rohrmann <tr...@apache.org>
Committed: Tue Jan 30 18:30:17 2018 +0100
----------------------------------------------------------------------
.../java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/23ff1203/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java b/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java
index 30cf377..ad7414c 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java
@@ -66,10 +66,10 @@ import org.apache.flink.runtime.rpc.FatalErrorHandler;
import org.apache.flink.runtime.rpc.RpcEndpoint;
import org.apache.flink.runtime.rpc.RpcService;
import org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils;
+import org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager;
import org.apache.flink.runtime.state.TaskLocalStateStore;
import org.apache.flink.runtime.state.TaskStateManager;
import org.apache.flink.runtime.state.TaskStateManagerImpl;
-import org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager;
import org.apache.flink.runtime.taskexecutor.exceptions.CheckpointException;
import org.apache.flink.runtime.taskexecutor.exceptions.PartitionException;
import org.apache.flink.runtime.taskexecutor.exceptions.SlotAllocationException;