This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
commit 0ac6b138733a175839220e6b03cc9bc9c89b0cc0
Author: huanghaibin <284824...@qq.com>
AuthorDate: Wed Feb 7 19:35:52 2024 +0800
[fix](group_commit) Fix write column id twice problem on wal file (#30935)
---
be/src/runtime/group_commit_mgr.cpp | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
diff --git a/be/src/runtime/group_commit_mgr.cpp
b/be/src/runtime/group_commit_mgr.cpp
index 7af4913b642..d98bf9efd1b 100644
--- a/be/src/runtime/group_commit_mgr.cpp
+++ b/be/src/runtime/group_commit_mgr.cpp
@@ -313,11 +313,12 @@ Status GroupCommitTable::_create_group_commit_load(
if (!is_pipeline) {
RETURN_IF_ERROR(load_block_queue->create_wal(
_db_id, _table_id, txn_id, label, _exec_env->wal_mgr(),
- params.desc_tbl.slotDescriptors, be_exe_version));
+
params.fragment.output_sink.olap_table_sink.schema.slot_descs, be_exe_version));
} else {
RETURN_IF_ERROR(load_block_queue->create_wal(
_db_id, _table_id, txn_id, label, _exec_env->wal_mgr(),
- pipeline_params.desc_tbl.slotDescriptors, be_exe_version));
+
pipeline_params.fragment.output_sink.olap_table_sink.schema.slot_descs,
+ be_exe_version));
}
_cv.notify_all();
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
