[fix](group_commit) Fix write column id twice problem on wal file (ap…

…ache#30935)
seawinde · Feb 7, 2024 · 54bfa6f · 54bfa6f
1 parent fbcf338
commit 54bfa6f
Showing 1 changed file with 3 additions and 2 deletions.
diff --git 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();
     }