From 15962747f37513852736ebd8125b14be616f15b2 Mon Sep 17 00:00:00 2001 From: Nishant Date: Wed, 13 Jul 2016 23:40:58 +0530 Subject: [PATCH] fix-3237 DruidBroker use FilteredServerInventoryView instead of ServerInventoryView --- .../server/coordination/broker/DruidBroker.java | 12 +++++++++--- 1 file changed, 9 insertions(+), 3 deletions(-) diff --git a/server/src/main/java/io/druid/server/coordination/broker/DruidBroker.java b/server/src/main/java/io/druid/server/coordination/broker/DruidBroker.java index 33ae3af970ab..b720f754e3ff 100644 --- a/server/src/main/java/io/druid/server/coordination/broker/DruidBroker.java +++ b/server/src/main/java/io/druid/server/coordination/broker/DruidBroker.java @@ -19,16 +19,20 @@ package io.druid.server.coordination.broker; +import com.google.common.base.Predicates; import com.google.common.util.concurrent.MoreExecutors; import com.google.inject.Inject; +import com.metamx.common.Pair; import com.metamx.common.lifecycle.LifecycleStart; import com.metamx.common.lifecycle.LifecycleStop; -import io.druid.client.ServerInventoryView; +import io.druid.client.FilteredServerInventoryView; import io.druid.client.ServerView; import io.druid.curator.discovery.ServiceAnnouncer; import io.druid.guice.ManageLifecycle; import io.druid.guice.annotations.Self; import io.druid.server.DruidNode; +import io.druid.server.coordination.DruidServerMetadata; +import io.druid.timeline.DataSegment; @ManageLifecycle public class DruidBroker @@ -39,7 +43,7 @@ public class DruidBroker @Inject public DruidBroker( - final ServerInventoryView serverInventoryView, + final FilteredServerInventoryView serverInventoryView, final @Self DruidNode self, final ServiceAnnouncer serviceAnnouncer ) @@ -57,7 +61,9 @@ public ServerView.CallbackAction segmentViewInitialized() serviceAnnouncer.announce(self); return ServerView.CallbackAction.UNREGISTER; } - } + }, + // We are not interested in any segment callbacks except view initialization + Predicates.>alwaysFalse() ); }