Apache
/
druid
mirror of https://github.com/apache/druid.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #1913 from druid-io/fix-zkc 

fix zkcoordinator inject
This commit is contained in:
Xavier Léauté 2015-11-04 21:34:30 -08:00
parent 3c3ea128cc 4efc90dda3
commit 2d4d3a40de
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
server/src/main/java/io/druid/server/coordination/ZkCoordinator.java
View File

@ -24,6 +24,7 @@ import com.google.common.base.Throwables;
import com.google.common.collect.Lists; import com.google.common.collect.Lists;
import com.google.common.collect.Queues; import com.google.common.collect.Queues;
import com.google.common.util.concurrent.SettableFuture; import com.google.common.util.concurrent.SettableFuture;
import com.google.inject.Inject;
import com.metamx.common.ISE; import com.metamx.common.ISE;
import com.metamx.common.concurrent.ScheduledExecutorFactory; import com.metamx.common.concurrent.ScheduledExecutorFactory;
import com.metamx.common.lifecycle.LifecycleStart; import com.metamx.common.lifecycle.LifecycleStart;
@ -76,6 +77,7 @@ public class ZkCoordinator implements DataSegmentChangeHandler
private volatile PathChildrenCache loadQueueCache; private volatile PathChildrenCache loadQueueCache;
private volatile boolean started = false; private volatile boolean started = false;
@Inject
public ZkCoordinator( public ZkCoordinator(
ObjectMapper jsonMapper, ObjectMapper jsonMapper,
SegmentLoaderConfig config, SegmentLoaderConfig config,