From 4efc90dda3d9d550ebda3a34f14c623b6e72fc33 Mon Sep 17 00:00:00 2001 From: fjy Date: Wed, 4 Nov 2015 17:30:17 -0800 Subject: [PATCH] fix zkcoordinator inject --- .../main/java/io/druid/server/coordination/ZkCoordinator.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/server/src/main/java/io/druid/server/coordination/ZkCoordinator.java b/server/src/main/java/io/druid/server/coordination/ZkCoordinator.java index 427f4dc6a454..7d38a3f57775 100644 --- a/server/src/main/java/io/druid/server/coordination/ZkCoordinator.java +++ b/server/src/main/java/io/druid/server/coordination/ZkCoordinator.java @@ -24,6 +24,7 @@ import com.google.common.collect.Lists; import com.google.common.collect.Queues; import com.google.common.util.concurrent.SettableFuture; +import com.google.inject.Inject; import com.metamx.common.ISE; import com.metamx.common.concurrent.ScheduledExecutorFactory; import com.metamx.common.lifecycle.LifecycleStart; @@ -76,6 +77,7 @@ public class ZkCoordinator implements DataSegmentChangeHandler private volatile PathChildrenCache loadQueueCache; private volatile boolean started = false; + @Inject public ZkCoordinator( ObjectMapper jsonMapper, SegmentLoaderConfig config,