This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.1 by this push:
new 1fab4b63eca [fix](group commit) should set wal id in runtime_state
when building pipeline task (#35552)
1fab4b63eca is described below
commit 1fab4b63eca1d836946c0f1a555361428108b83b
Author: huanghaibin <[email protected]>
AuthorDate: Tue May 28 20:17:29 2024 +0800
[fix](group commit) should set wal id in runtime_state when building
pipeline task (#35552)
pick from master #35445
---
be/src/pipeline/pipeline_fragment_context.cpp | 3 +++
gensrc/thrift/PaloInternalService.thrift | 1 +
2 files changed, 4 insertions(+)
diff --git a/be/src/pipeline/pipeline_fragment_context.cpp
b/be/src/pipeline/pipeline_fragment_context.cpp
index e3f9de5fd03..0e2c8419967 100644
--- a/be/src/pipeline/pipeline_fragment_context.cpp
+++ b/be/src/pipeline/pipeline_fragment_context.cpp
@@ -274,6 +274,9 @@ Status PipelineFragmentContext::prepare(const
doris::TPipelineFragmentParams& re
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);
+ }
if (request.query_options.__isset.is_report_success) {
fragment_context->set_is_report_success(request.query_options.is_report_success);
diff --git a/gensrc/thrift/PaloInternalService.thrift
b/gensrc/thrift/PaloInternalService.thrift
index dcfa72ee930..78790260b51 100644
--- a/gensrc/thrift/PaloInternalService.thrift
+++ b/gensrc/thrift/PaloInternalService.thrift
@@ -741,6 +741,7 @@ struct TPipelineFragmentParams {
38: optional i32 total_instances
39: optional map<i32, i32> shuffle_idx_to_instance_idx
40: optional bool is_nereids = true;
+ 41: optional i64 wal_id
// For cloud
1000: optional bool is_mow_table;
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
