(fix)[group commit] Row count is incorrect when enable pipeline load (#…

…30447)
apache · Jan 26, 2024 · 1286f34 · 1286f34
1 parent 23838c1
commit 1286f34
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/be/src/runtime/stream_load/stream_load_executor.cpp b/be/src/runtime/stream_load/stream_load_executor.cpp
@@ -101,7 +101,7 @@ Status StreamLoadExecutor::execute_plan_fragment(std::shared_ptr<StreamLoadConte
                         ctx->number_loaded_rows);
             }
         } else {
-            if (ctx->group_commit && status->is<DATA_QUALITY_ERROR>()) {
+            if (ctx->group_commit) {
                 ctx->number_total_rows = state->num_rows_load_total();
                 ctx->number_loaded_rows = state->num_rows_load_success();
                 ctx->number_filtered_rows = state->num_rows_load_filtered();