This is an automated email from the ASF dual-hosted git repository.
kfaraz 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 6964297b530 Remove the unused Controller context reference from Worker
(#16285)
6964297b530 is described below
commit 6964297b53023f4402a3aa90e419fe469e8ea415
Author: YongGang <[email protected]>
AuthorDate: Mon Apr 15 20:04:24 2024 -0700
Remove the unused Controller context reference from Worker (#16285)
---
.../src/main/java/org/apache/druid/msq/exec/ControllerImpl.java | 4 +---
.../java/org/apache/druid/msq/util/MultiStageQueryContext.java | 7 -------
2 files changed, 1 insertion(+), 10 deletions(-)
diff --git
a/extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/exec/ControllerImpl.java
b/extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/exec/ControllerImpl.java
index 878492d8a6e..0d1eb5004a7 100644
---
a/extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/exec/ControllerImpl.java
+++
b/extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/exec/ControllerImpl.java
@@ -718,9 +718,7 @@ public class ControllerImpl implements Controller
MSQControllerTask.isReplaceInputDataSourceTask(task)
);
- // propagate the controller's context and tags to the worker task
- taskContextOverridesBuilder.put(MultiStageQueryContext.CTX_OF_CONTROLLER,
task.getContext());
- // specifically assign the 'tags' field for enhanced worker task metrics
reporting
+ // propagate the controller's tags to the worker task for enhanced metrics
reporting
Map<String, Object> tags = task.getContextValue(DruidMetrics.TAGS);
if (tags != null) {
taskContextOverridesBuilder.put(DruidMetrics.TAGS, tags);
diff --git
a/extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/util/MultiStageQueryContext.java
b/extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/util/MultiStageQueryContext.java
index 0fd8e4f51f3..60734b5b1da 100644
---
a/extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/util/MultiStageQueryContext.java
+++
b/extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/util/MultiStageQueryContext.java
@@ -143,13 +143,6 @@ public class MultiStageQueryContext
public static final String CTX_IS_REINDEX = "isReindex";
- /**
- * Key for controller task's context passed to worker tasks.
- * Facilitates sharing the controller's execution environment
- * and configurations with its associated worker tasks.
- */
- public static final String CTX_OF_CONTROLLER = "controllerCtx";
-
/**
* Controls sort order within segments. Normally, this is the same as the
overall order of the query (from the
* CLUSTERED BY clause) but it can be overridden.
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
