You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@druid.apache.org by ca...@apache.org on 2026/10/14 15:01:40 UTC
(druid) branch master updated: use provider that is called at query time instead of constructor (#20537)
This is an automated email from the ASF dual-hosted git repository.
capistrant pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/druid.git
The following commit(s) were added to refs/heads/master by this push:
new f75fd1fae3a use provider that is called at query time instead of constructor (#20537)
f75fd1fae3a is described below
commit f75fd1fae3a388eaeabf76739dfc8e77a3581b87
Author: Lucas Capistrant <ca...@users.noreply.github.com>
AuthorDate: Wed Oct 14 10:01:33 2026 -0500
use provider that is called at query time instead of constructor (#20537)
---
.../msq/dart/controller/DartControllerContextFactoryImpl.java | 8 +++-----
1 file changed, 3 insertions(+), 5 deletions(-)
diff --git a/multi-stage-query/src/main/java/org/apache/druid/msq/dart/controller/DartControllerContextFactoryImpl.java b/multi-stage-query/src/main/java/org/apache/druid/msq/dart/controller/DartControllerContextFactoryImpl.java
index a5839d20b58..c6f0e92fd7b 100644
--- a/multi-stage-query/src/main/java/org/apache/druid/msq/dart/controller/DartControllerContextFactoryImpl.java
+++ b/multi-stage-query/src/main/java/org/apache/druid/msq/dart/controller/DartControllerContextFactoryImpl.java
@@ -23,7 +23,6 @@ import com.fasterxml.jackson.databind.ObjectMapper;
import com.google.inject.Inject;
import com.google.inject.Injector;
import org.apache.druid.client.TimelineServerView;
-import org.apache.druid.discovery.DruidNodeDiscovery;
import org.apache.druid.discovery.DruidNodeDiscoveryProvider;
import org.apache.druid.discovery.NodeRole;
import org.apache.druid.guice.annotations.EscalatedGlobal;
@@ -56,7 +55,7 @@ public class DartControllerContextFactoryImpl implements DartControllerContextFa
protected final MemoryIntrospector memoryIntrospector;
protected final List<InputSpecSlicerProvider> inputSpecSlicerProviders;
protected final ServiceEmitter emitter;
- protected final DruidNodeDiscovery dartWorkerDiscovery;
+ protected final DruidNodeDiscoveryProvider discoveryProvider;
@Inject
public DartControllerContextFactoryImpl(
@@ -81,8 +80,7 @@ public class DartControllerContextFactoryImpl implements DartControllerContextFa
this.memoryIntrospector = memoryIntrospector;
this.inputSpecSlicerProviders = List.copyOf(inputSpecSlicerProviders);
this.emitter = emitter;
- this.dartWorkerDiscovery =
- discoveryProvider.getForServiceAndRoles(DartWorkerService.NAME, Set.of(NodeRole.HISTORICAL));
+ this.discoveryProvider = discoveryProvider;
}
@Override
@@ -99,7 +97,7 @@ public class DartControllerContextFactoryImpl implements DartControllerContextFa
inputSpecSlicerProviders,
emitter,
context,
- dartWorkerDiscovery
+ discoveryProvider.getForServiceAndRoles(DartWorkerService.NAME, Set.of(NodeRole.HISTORICAL))
);
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@druid.apache.org
For additional commands, e-mail: commits-help@druid.apache.org