You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by hs...@apache.org on 2015/03/27 19:34:32 UTC
flink git commit: [FLINK-1790]Remove the redundant import code
Repository: flink
Updated Branches:
refs/heads/master c9d29f264 -> 9c0a45398
[FLINK-1790]Remove the redundant import code
Remove the redundant import code in TaskManager
Author: hongsibao <ho...@huawei.com>
Closes #538 from matadorhong/RemoveRedundantImport and squashes the following commits:
1f80c0d [hongsibao] Remove the redunant import code
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/9c0a4539
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/9c0a4539
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/9c0a4539
Branch: refs/heads/master
Commit: 9c0a453981761595ad8dc09ed5bb297583360635
Parents: c9d29f2
Author: hongsibao <ho...@huawei.com>
Authored: Fri Mar 27 11:34:23 2015 -0700
Committer: Henry Saputra <he...@gmail.com>
Committed: Fri Mar 27 11:34:23 2015 -0700
----------------------------------------------------------------------
.../scala/org/apache/flink/runtime/taskmanager/TaskManager.scala | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/9c0a4539/flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala b/flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala
index 2f262c9..a9bebca 100644
--- a/flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala
+++ b/flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala
@@ -20,7 +20,7 @@ package org.apache.flink.runtime.taskmanager
import java.io.{File, IOException}
import java.net.{InetAddress, InetSocketAddress}
import java.util
-import java.util.concurrent.{FutureTask, TimeUnit}
+import java.util.concurrent.FutureTask
import management.{GarbageCollectorMXBean, ManagementFactory, MemoryMXBean}
import akka.actor._
@@ -43,7 +43,7 @@ import org.apache.flink.runtime.executiongraph.ExecutionAttemptID
import org.apache.flink.runtime.filecache.FileCache
import org.apache.flink.runtime.instance.{HardwareDescription, InstanceConnectionInfo, InstanceID}
import org.apache.flink.runtime.io.disk.iomanager.IOManager.IOMode
-import org.apache.flink.runtime.io.disk.iomanager.{IOManager, IOManagerAsync}
+import org.apache.flink.runtime.io.disk.iomanager.IOManagerAsync
import org.apache.flink.runtime.io.network.NetworkEnvironment
import org.apache.flink.runtime.io.network.netty.NettyConfig
import org.apache.flink.runtime.jobgraph.IntermediateDataSetID