Prefer default parallelism to avoid adding extra local exchange
For partitioned writes the shuffle is added unconditionally. There's
no reason to additionally prefer the fixed streams.
@@ -549,7 +549,7 @@ public class AddLocalExchanges
}
}
else {
- PlanWithProperties source = originalTableWriterNode.getSource().accept(this, fixedParallelism());
+ PlanWithProperties source = originalTableWriterNode.getSource().accept(this, defaultParallelism(session));
PlanWithProperties exchange = deriveProperties(
partitionedExchange(
idAllocator.getNextId(),
