Remove the unused Controller context reference from Worker (#16285)
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 878492d..0d1eb50 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 @@
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 0fd8e4f..60734b5 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
@@ -144,13 +144,6 @@
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.
*/
