From a8b674e00d9ccad334b8ed6ecb3712dc7e3259b8 Mon Sep 17 00:00:00 2001 From: Clint Wylie Date: Wed, 23 Oct 2019 15:52:57 -0700 Subject: [PATCH] fix indexer when used with http inventory view (#8723) --- .../java/org/apache/druid/cli/CliIndexer.java | 24 ++++++++++++++++++- 1 file changed, 23 insertions(+), 1 deletion(-) diff --git a/services/src/main/java/org/apache/druid/cli/CliIndexer.java b/services/src/main/java/org/apache/druid/cli/CliIndexer.java index 42d24ac2661..0b3b283eec4 100644 --- a/services/src/main/java/org/apache/druid/cli/CliIndexer.java +++ b/services/src/main/java/org/apache/druid/cli/CliIndexer.java @@ -25,7 +25,10 @@ import com.google.inject.Inject; import com.google.inject.Module; import com.google.inject.Provides; import com.google.inject.name.Names; +import com.google.inject.util.Providers; import io.airlift.airline.Command; +import org.apache.druid.client.DruidServer; +import org.apache.druid.discovery.DataNodeService; import org.apache.druid.discovery.LookupNodeService; import org.apache.druid.discovery.NodeType; import org.apache.druid.discovery.WorkerNodeService; @@ -58,6 +61,7 @@ import org.apache.druid.segment.realtime.CliIndexerDataSegmentServerAnnouncerLif import org.apache.druid.segment.realtime.appenderator.AppenderatorsManager; import org.apache.druid.segment.realtime.appenderator.UnifiedIndexerAppenderatorsManager; import org.apache.druid.server.DruidNode; +import org.apache.druid.server.coordination.SegmentLoadDropHandler; import org.apache.druid.server.coordination.ServerType; import org.apache.druid.server.http.SegmentListerResource; import org.apache.druid.server.initialization.jetty.CliIndexerServerModule; @@ -142,11 +146,17 @@ public class CliIndexer extends ServerRunnable LifecycleModule.register(binder, Server.class, RemoteChatHandler.class); + binder.bind(SegmentLoadDropHandler.class).toProvider(Providers.of(null)); + bindAnnouncer( binder, DiscoverySideEffectsProvider.builder(NodeType.INDEXER) .serviceClasses( - ImmutableList.of(LookupNodeService.class, WorkerNodeService.class) + ImmutableList.of( + LookupNodeService.class, + WorkerNodeService.class, + DataNodeService.class + ) ) .build() ); @@ -177,6 +187,18 @@ public class CliIndexer extends ServerRunnable WorkerConfig.DEFAULT_CATEGORY ); } + + @Provides + @LazySingleton + public DataNodeService getDataNodeService() + { + return new DataNodeService( + DruidServer.DEFAULT_TIER, + 0L, + ServerType.INDEXER_EXECUTOR, + DruidServer.DEFAULT_PRIORITY + ); + } }, new IndexingServiceFirehoseModule(), new IndexingServiceTaskLogsModule(),