Skip to content

Commit

Permalink
[BugFix] only enable parallel merge when has sort exprs (#50411)
Browse files Browse the repository at this point in the history
Signed-off-by: stdpain <[email protected]>
  • Loading branch information
stdpain authored Aug 29, 2024
1 parent c610121 commit 690a988
Showing 1 changed file with 3 additions and 2 deletions.
5 changes: 3 additions & 2 deletions be/src/exec/topn_node.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -372,8 +372,9 @@ pipeline::OpFactories TopNNode::decompose_to_pipeline(pipeline::PipelineBuilderC
bool is_partition_skewed =
_tnode.sort_node.__isset.analytic_partition_skewed && _tnode.sort_node.analytic_partition_skewed;
bool need_merge = _analytic_partition_exprs.empty() || is_partition_skewed;
bool enable_parallel_merge =
_tnode.sort_node.__isset.enable_parallel_merge && _tnode.sort_node.enable_parallel_merge;
bool enable_parallel_merge = _tnode.sort_node.__isset.enable_parallel_merge &&
_tnode.sort_node.enable_parallel_merge &&
!_sort_exec_exprs.lhs_ordering_expr_ctxs().empty();

OpFactories operators_source_with_sort;

Expand Down

0 comments on commit 690a988

Please sign in to comment.