macthed all data

databendlabs · Nov 6, 2023 · a93cc9e · a93cc9e
1 parent 96cd7c6
commit a93cc9e
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/query/service/src/pipelines/processors/transforms/processor_accumulate_row_number.rs b/src/query/service/src/pipelines/processors/transforms/processor_accumulate_row_number.rs
@@ -50,7 +50,9 @@ impl AccumulateRowNumber {
         // if matched all source data, we will get an empty block, but which
         // has source join schema,not only row_number,for combound_block project,
         // it will do nothing for empty block.
-        assert_eq!(data_block.num_columns(), 1);
+        if !data_block.is_empty() {
+            assert_eq!(data_block.num_columns(), 1);
+        }
         assert_eq!(
             data_block.get_by_offset(0).data_type,
             DataType::Number(NumberDataType::UInt64)