From 7cde445dd739f66dbea8d94572dd10370e42112c Mon Sep 17 00:00:00 2001 From: sviatahorau Date: Wed, 26 Jun 2024 14:50:39 +0200 Subject: [PATCH] Fixed RuntimeException during ordered scan msq query --- .../java/org/apache/druid/msq/querykit/scan/ScanQueryKit.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/querykit/scan/ScanQueryKit.java b/extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/querykit/scan/ScanQueryKit.java index 2927264382a4..a72bd9643931 100644 --- a/extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/querykit/scan/ScanQueryKit.java +++ b/extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/querykit/scan/ScanQueryKit.java @@ -185,7 +185,7 @@ public QueryDefinition makeQueryDefinition( .inputs(new StageInputSpec(firstStageNumber)) .signature(signatureToUse) .maxWorkerCount(1) - .shuffleSpec(null) // no shuffling should be required after a limit processor. + .shuffleSpec(MixShuffleSpec.instance()) // no shuffling should be required after a limit processor. .processorFactory( new OffsetLimitFrameProcessorFactory( queryToRun.getScanRowsOffset(),