somu-imply commented on code in PR #15470:
URL: https://github.com/apache/druid/pull/15470#discussion_r1475588458
##########
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/exec/ControllerImpl.java:
##########
@@ -2728,8 +2731,21 @@ private void startStages() throws IOException,
InterruptedException
throw new MSQException(new
InsertCannotBeEmptyFault(task.getDataSource()));
}
- final ClusterByPartitions partitionBoundaries =
- queryKernel.getResultPartitionBoundariesForStage(shuffleStageId);
+ // Q for MSQ folks
+ // I am not sure why can't we switch to universal
+ // if the partition boundary for a stage derived from the last valid
shuffle spec
+ // is not ready, especially when the stage before the final has a
shuffle spec of null
+ final ClusterByPartitions partitionBoundaries;
Review Comment:
reverted, moved to single partition at all places inside WindowQueryKit
which solved it
--
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]
