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 878492d8a6e8..0d1eb5004a71 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 @@ private QueryDefinition initializeQueryDefAndState(final Closer closer) 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 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 0fd8e4f51f31..60734b5b1dad 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.