Don't try grouped execution for forceSingleNode
Grouped execution is not supported for SystemPartitioningHandles, and
will fail gettting the bucket node map. forceSingleNode uses
SystemPartitioningHandle.SINGLE_DISTRIBUTION as the partitioning.
@@ -194,7 +194,10 @@ public class PlanFragmenter
SubPlan subPlan = fragmenter.buildRootFragment(root, properties);
subPlan = reassignPartitioningHandleIfNecessary(session, subPlan);
+ if (!forceSingleNode) {
+ // grouped execution is not supported for SINGLE_DISTRIBUTION
subPlan = analyzeGroupedExecution(session, subPlan, false);
+ }
checkState(!isForceSingleNodeOutput(session) || subPlan.getFragment().getPartitioning().isSingleNode(), "Root of PlanFragment is not single node");
