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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
