fix

SkyFan2002 · SkyFan2002 · commit 6a8a3520a149 · 2025-04-30T14:16:11.000+08:00
diff --git a/src/query/service/src/pipelines/pipeline_builder.rs b/src/query/service/src/pipelines/pipeline_builder.rs
@@ -220,6 +220,8 @@ impl PipelineBuilder {
             }
             PhysicalPlan::Shuffle(shuffle) => self.build_shuffle(shuffle),
             PhysicalPlan::Duplicate(duplicate) => self.build_duplicate(duplicate),
+            PhysicalPlan::BroadcastSource(source) => self.build_broadcast_source(source),
+            PhysicalPlan::BroadcastSink(sink) => self.build_broadcast_sink(sink),
 
             // ==============================
             // 4. Data Modification Operations

Original file line number	Diff line number	Diff line change
`@@ -220,6 +220,8 @@ impl PipelineBuilder {`
`220`	`220`	`}`
`221`	`221`	`PhysicalPlan::Shuffle(shuffle) => self.build_shuffle(shuffle),`
`222`	`222`	`PhysicalPlan::Duplicate(duplicate) => self.build_duplicate(duplicate),`
	`223`	`+ PhysicalPlan::BroadcastSource(source) => self.build_broadcast_source(source),`
	`224`	`+ PhysicalPlan::BroadcastSink(sink) => self.build_broadcast_sink(sink),`
`223`	`225`
`224`	`226`	`// ==============================`
`225`	`227`	`// 4. Data Modification Operations`