Skip to content

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
  • Loading branch information
BiteTheDDDDt committed Jun 13, 2024
1 parent ba89258 commit 40c4384
Showing 1 changed file with 2 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -154,7 +154,8 @@ public Void visitPhysicalIcebergTableSink(

@Override
public Void visitPhysicalResultSink(PhysicalResultSink<? extends Plan> physicalResultSink, PlanContext context) {
if (context.getSessionVariable().enableParallelResultSink()) {
if (context.getSessionVariable().enableParallelResultSink()
&& !context.getStatementContext().isShortCircuitQuery()) {
addRequestPropertyToChildren(PhysicalProperties.ANY);
} else {
addRequestPropertyToChildren(PhysicalProperties.GATHER);
Expand Down

0 comments on commit 40c4384

Please sign in to comment.