From 053f2e9269afac64ded01e89df219d718508a0e3 Mon Sep 17 00:00:00 2001 From: Vishesh Garg Date: Thu, 27 Jun 2024 09:03:19 +0530 Subject: [PATCH] Fix build --- .../java/org/apache/druid/msq/indexing/MSQCompactionRunner.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/MSQCompactionRunner.java b/extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/MSQCompactionRunner.java index 0ec04fcc09dd..aab55a52dab2 100644 --- a/extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/MSQCompactionRunner.java +++ b/extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/MSQCompactionRunner.java @@ -256,6 +256,7 @@ private static MSQTuningConfig buildMSQTuningConfig(CompactionTask compactionTas // We don't consider maxRowsInMemory coming via CompactionTuningConfig since it always sets a default value if no // value specified by user. final int maxRowsInMemory = MultiStageQueryContext.getRowsInMemory(compactionTaskContext); + final Integer maxNumSegments = MultiStageQueryContext.getMaxNumSegments(compactionTaskContext); Integer rowsPerSegment = getRowsPerSegment(compactionTask); @@ -263,6 +264,7 @@ private static MSQTuningConfig buildMSQTuningConfig(CompactionTask compactionTas maxNumWorkers, maxRowsInMemory, rowsPerSegment, + maxNumSegments, compactionTask.getTuningConfig() != null ? compactionTask.getTuningConfig().getIndexSpec() : null ); }