This is an automated email from the ASF dual-hosted git repository. karan pushed a commit to branch 26.0.0 in repository https://gitbox.apache.org/repos/asf/druid.git
commit bac56bfda7c674cab320ae0bdc4534860b0149ed Author: Karan Kumar <[email protected]> AuthorDate: Mon Apr 17 18:01:24 2023 +0530 Adding more logs for sequential merge. (#14097) (cherry picked from commit be6745f75ba437bcd0aec15217ce69955ebd8603) --- .../apache/druid/msq/kernel/controller/ControllerStageTracker.java | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/kernel/controller/ControllerStageTracker.java b/extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/kernel/controller/ControllerStageTracker.java index 67dd1628c0..6619f389f6 100644 --- a/extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/kernel/controller/ControllerStageTracker.java +++ b/extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/kernel/controller/ControllerStageTracker.java @@ -54,6 +54,7 @@ import org.apache.druid.msq.statistics.CompleteKeyStatisticsInformation; import org.apache.druid.msq.statistics.PartialKeyStatisticsInformation; import javax.annotation.Nullable; +import java.util.Date; import java.util.HashMap; import java.util.HashSet; import java.util.List; @@ -558,6 +559,11 @@ class ControllerStageTracker workers.remove(workerNumber); if (workers.isEmpty()) { // generate partition boundaries since all work is finished for the time chunk + log.info( + "Generating partition boundaries from stage: %d of time chunk: [%s] GMT", + stageDef.getStageNumber(), + new Date(timeChunk) + ); ClusterByStatisticsCollector collector = timeChunkToCollector.get(tc); Either<Long, ClusterByPartitions> countOrPartitions = stageDef.generatePartitionBoundariesForShuffle(collector); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
