[partitionsort](fix) Fix DCHECK failure (#33035)

apache · Mar 29, 2024 · 9d265aa · 9d265aa
1 parent 52ed33f
commit 9d265aa
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 4 deletions.
diff --git a/be/src/pipeline/exec/partition_sort_sink_operator.cpp b/be/src/pipeline/exec/partition_sort_sink_operator.cpp
@@ -141,8 +141,6 @@ Status PartitionSortSinkOperatorX::sink(RuntimeState* state, vectorized::Block*
             local_state._value_places[i]->create_or_reset_sorter_state();
             auto sorter = std::move(local_state._value_places[i]->_partition_topn_sorter);
 
-            DCHECK(_child_x->row_desc().num_materialized_slots() ==
-                   local_state._value_places[i]->_blocks.back()->columns());
             //get blocks from every partition, and sorter get those data.
             for (const auto& block : local_state._value_places[i]->_blocks) {
                 RETURN_IF_ERROR(sorter->append_block(block.get()));

diff --git a/be/src/vec/exec/vpartition_sort_node.cpp b/be/src/vec/exec/vpartition_sort_node.cpp
@@ -263,8 +263,6 @@ Status VPartitionSortNode::sink(RuntimeState* state, vectorized::Block* input_bl
             _value_places[i]->create_or_reset_sorter_state();
             auto sorter = std::ref(_value_places[i]->_partition_topn_sorter);
 
-            DCHECK(child(0)->row_desc().num_materialized_slots() ==
-                   _value_places[i]->_blocks.back()->columns());
             //get blocks from every partition, and sorter get those data.
             for (const auto& block : _value_places[i]->_blocks) {
                 RETURN_IF_ERROR(sorter.get()->append_block(block.get()));