change by review

HappenLee · Jan 2, 2025 · 3f975aa · 3f975aa
1 parent 360fc22
commit 3f975aa
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/be/src/pipeline/exec/partition_sort_source_operator.cpp b/be/src/pipeline/exec/partition_sort_source_operator.cpp
@@ -77,10 +77,10 @@ Status PartitionSortSourceOperatorX::get_block(RuntimeState* state, vectorized::
         }
     }
 
-    //if buffer have no data and sink not eos, block reading and wait for signal again
-    RETURN_IF_ERROR(vectorized::VExprContext::filter_block(local_state._conjuncts, output_block,
-                                                           output_block->columns()));
     if (!output_block->empty()) {
+        //if buffer have no data and sink not eos, block reading and wait for signal again
+        RETURN_IF_ERROR(vectorized::VExprContext::filter_block(local_state._conjuncts, output_block,
+                                                               output_block->columns()));
         local_state._num_rows_returned += output_block->rows();
     }
     return Status::OK();