cryptoe commented on code in PR #13790:
URL: https://github.com/apache/druid/pull/13790#discussion_r1105285582
##########
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/exec/WorkerImpl.java:
##########
@@ -582,12 +588,14 @@ public void postCleanupStage(final StageId stageId)
@Override
public void postFinish()
{
+ log.info("Finish received");
kernelManipulationQueue.add(KernelHolder::setDone);
}
@Override
public ClusterByStatisticsSnapshot fetchStatisticsSnapshot(StageId stageId)
{
+ log.info("Fetching statistics for stage:[%d]", stageId.getStageNumber());
Review Comment:
Each worker can only have one taskID and each log is generally task log is
generally pulled from the druid console.
In the case, people are using popular log agg tools, then they should add a
dimension taskId to the "log line" via the constructs provided by the tool,
"looking at file name in case of druid to figure out the taskId" is one such
approach.
Hence I am not pushing taskId everywhere which just bloats the message.
--
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]
