update

Gabriel39 · Gabriel39 · commit d6be3efbdd35 · 2026-02-14T18:32:06.000+08:00
diff --git a/be/src/pipeline/pipeline_fragment_context.cpp b/be/src/pipeline/pipeline_fragment_context.cpp
@@ -2099,8 +2099,6 @@ Status PipelineFragmentContext::set_to_rerun() {
 Status PipelineFragmentContext::rebuild(ThreadPool* thread_pool) {
     _submitted = false;
     _is_fragment_instance_closed = false;
-    // _require_bucket_distribution may be set to true to affect the building of pipeline with local shuffle
-    _require_bucket_distribution = false;
     return _build_and_prepare_full_pipeline(thread_pool);
 }
 

Original file line number	Diff line number	Diff line change
`@@ -2099,8 +2099,6 @@ Status PipelineFragmentContext::set_to_rerun() {`
`2099`	`2099`	`Status PipelineFragmentContext::rebuild(ThreadPool* thread_pool) {`
`2100`	`2100`	`_submitted = false;`
`2101`	`2101`	`_is_fragment_instance_closed = false;`
`2102`		`- // _require_bucket_distribution may be set to true to affect the building of pipeline with local shuffle`
`2103`		`- _require_bucket_distribution = false;`
`2104`	`2102`	`return _build_and_prepare_full_pipeline(thread_pool);`
`2105`	`2103`	`}`
`2106`	`2104`