Apache
/
druid
mirror of https://github.com/apache/druid.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Remove the unused Controller context reference from Worker (#16285)

This commit is contained in:
YongGang 2024-04-15 20:04:24 -07:00 committed by GitHub
parent a805c5612e
commit 6964297b53
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 1 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/exec/ControllerImpl.java
View File

@ -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);

7
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/util/MultiStageQueryContext.java
View File

@ -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.