database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[fix](group_commit) Fix write column id twice problem on wal file (#30935)

Browse Source
This commit is contained in:
huanghaibin
2024-02-07 19:35:52 +08:00
committed by yiguolei
parent 366a6792bf
commit 5bb8a72626
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
be/src/runtime/group_commit_mgr.cpp
View File

@ -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();
}