This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 1286f3461bd (fix)[group commit] Row count is incorrect when enable
pipeline load (#30447)
1286f3461bd is described below
commit 1286f3461bdb4e559d9bbd93d0e34e43e738c050
Author: meiyi <[email protected]>
AuthorDate: Sat Jan 27 00:01:45 2024 +0800
(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 1fc8eb81207..386db8c8497 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_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();
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
