LakshSingla commented on code in PR #16790:
URL: https://github.com/apache/druid/pull/16790#discussion_r1695064626
##########
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/kernel/worker/WorkerStagePhase.java:
##########
@@ -54,11 +54,12 @@ public boolean canTransitionFrom(final WorkerStagePhase
priorPhase)
@Override
public boolean canTransitionFrom(final WorkerStagePhase priorPhase)
{
- return priorPhase == PRESHUFFLE_WAITING_FOR_RESULT_PARTITION_BOUNDARIES;
+ return priorPhase == PRESHUFFLE_WAITING_FOR_RESULT_PARTITION_BOUNDARIES
/* if globally sorting */
+ || priorPhase == READING_INPUT /* if locally sorting */;
Review Comment:
Why did this not get caught before this patch?
--
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: commits-unsubscr...@druid.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@druid.apache.org
For additional commands, e-mail: commits-h...@druid.apache.org
