From 1286f3461bdb4e559d9bbd93d0e34e43e738c050 Mon Sep 17 00:00:00 2001 From: meiyi Date: Sat, 27 Jan 2024 00:01:45 +0800 Subject: [PATCH] (fix)[group commit] Row count is incorrect when enable pipeline load (#30447) --- be/src/runtime/stream_load/stream_load_executor.cpp | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/be/src/runtime/stream_load/stream_load_executor.cpp b/be/src/runtime/stream_load/stream_load_executor.cpp index 1fc8eb812072dd..386db8c849724a 100644 --- 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_ptrnumber_loaded_rows); } } else { - if (ctx->group_commit && status->is()) { + 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();