fix build pipeline

SkyFan2002 · SkyFan2002 · commit 45dc770906f6 · 2025-04-22T16:05:18.000+08:00
diff --git a/src/query/service/src/pipelines/builders/builder_runtime_filter.rs b/src/query/service/src/pipelines/builders/builder_runtime_filter.rs
@@ -34,7 +34,8 @@ impl PipelineBuilder {
         )
     }
 
-    pub(crate) fn build_runtime_filter_sink(&mut self, _sink: &RuntimeFilterSink) -> Result<()> {
+    pub(crate) fn build_runtime_filter_sink(&mut self, sink: &RuntimeFilterSink) -> Result<()> {
+        self.build_pipeline(&sink.input)?;
         self.main_pipeline
             .add_sink(RuntimeFilterSinkProcessor::create)
     }

Original file line number	Diff line number	Diff line change
`@@ -34,7 +34,8 @@ impl PipelineBuilder {`
`34`	`34`	`)`
`35`	`35`	`}`
`36`	`36`
`37`		`- pub(crate) fn build_runtime_filter_sink(&mut self, _sink: &RuntimeFilterSink) -> Result<()> {`
	`37`	`+ pub(crate) fn build_runtime_filter_sink(&mut self, sink: &RuntimeFilterSink) -> Result<()> {`
	`38`	`+ self.build_pipeline(&sink.input)?;`
`38`	`39`	`self.main_pipeline`
`39`	`40`	`.add_sink(RuntimeFilterSinkProcessor::create)`
`40`	`41`	`}`