This is an automated email from the ASF dual-hosted git repository. dataroaring pushed a commit to branch branch-3.0 in repository https://gitbox.apache.org/repos/asf/doris.git
commit 1c8bd8adbca6a87d6285337b67b758485ed8a6c4 Author: huanghaibin <[email protected]> AuthorDate: Tue May 28 09:30:47 2024 +0800 [fix](group commit) should set wal id in runtime_state when building pipeline task (#35445) after commit https://github.com/apache/doris/commit/85026759d6ed8d89240beb1b546b08c67db098d7, stream load using pipeline engine to load data, wal id should be setted in runtime_state when building pipeline task, like plan_fragment_executor does. Wal id in runtime_state is used to find wal file. --- be/src/pipeline/pipeline_fragment_context.cpp | 3 +++ 1 file changed, 3 insertions(+) diff --git a/be/src/pipeline/pipeline_fragment_context.cpp b/be/src/pipeline/pipeline_fragment_context.cpp index 89588e39471..34bce1c53ba 100644 --- a/be/src/pipeline/pipeline_fragment_context.cpp +++ b/be/src/pipeline/pipeline_fragment_context.cpp @@ -378,6 +378,9 @@ Status PipelineFragmentContext::_build_pipeline_tasks( if (request.__isset.load_job_id) { runtime_state->set_load_job_id(request.load_job_id); } + if (request.__isset.wal_id) { + runtime_state->set_wal_id(request.wal_id); + } runtime_state->set_desc_tbl(_desc_tbl); runtime_state->set_per_fragment_instance_idx(local_params.sender_id); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
