diff options
Diffstat (limited to 'exec/java-exec/src/main/java/org/apache/drill/exec/rpc/control')
-rw-r--r-- | exec/java-exec/src/main/java/org/apache/drill/exec/rpc/control/ControlClient.java | 1 | ||||
-rw-r--r-- | exec/java-exec/src/main/java/org/apache/drill/exec/rpc/control/WorkEventBus.java | 4 |
2 files changed, 0 insertions, 5 deletions
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/rpc/control/ControlClient.java b/exec/java-exec/src/main/java/org/apache/drill/exec/rpc/control/ControlClient.java index 1df5ff1b5..d74402a22 100644 --- a/exec/java-exec/src/main/java/org/apache/drill/exec/rpc/control/ControlClient.java +++ b/exec/java-exec/src/main/java/org/apache/drill/exec/rpc/control/ControlClient.java @@ -17,7 +17,6 @@ */ package org.apache.drill.exec.rpc.control; -import com.google.common.collect.ImmutableList; import com.google.protobuf.MessageLite; import io.netty.buffer.ByteBuf; import io.netty.channel.ChannelFuture; diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/rpc/control/WorkEventBus.java b/exec/java-exec/src/main/java/org/apache/drill/exec/rpc/control/WorkEventBus.java index cb5b1f946..a10ea2900 100644 --- a/exec/java-exec/src/main/java/org/apache/drill/exec/rpc/control/WorkEventBus.java +++ b/exec/java-exec/src/main/java/org/apache/drill/exec/rpc/control/WorkEventBus.java @@ -19,9 +19,7 @@ package org.apache.drill.exec.rpc.control; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentMap; -import java.util.concurrent.TimeUnit; -import org.apache.drill.exec.exception.FragmentSetupException; import org.apache.drill.exec.proto.BitControl.FragmentStatus; import org.apache.drill.exec.proto.ExecProtos.FragmentHandle; import org.apache.drill.exec.proto.UserBitShared.QueryId; @@ -30,8 +28,6 @@ import org.apache.drill.exec.work.foreman.FragmentStatusListener; import org.apache.drill.exec.work.foreman.ForemanSetupException; import org.apache.drill.exec.work.fragment.FragmentManager; -import com.google.common.cache.Cache; -import com.google.common.cache.CacheBuilder; import com.google.common.collect.Maps; public class WorkEventBus { |