adarshsanjeev commented on code in PR #16943:
URL: https://github.com/apache/druid/pull/16943#discussion_r1727180982
##########
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/exec/WorkerImpl.java:
##########
@@ -408,6 +408,7 @@ private void handleNewWorkOrder(
final QueryContext queryContext = task != null ?
QueryContext.of(task.getContext()) : QueryContext.empty();
final RunWorkOrder runWorkOrder = new RunWorkOrder(
+ task.getControllerTaskId(),
Review Comment:
The stage id and controller task id seem to be always the same for now for
all queries after the controller refactor, so it would not get caught in one
branch. I think this would only be caught during an upgrade scenario where IDs
were getting randomly generated from previous versions of controller, or we add
some functionality which causes a worker id to have other stage ids.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
