update unimplemented msg for LogicalRecursiveUnion & LogicalCteRef

risingwavelabs · May 14, 2024 · ce16c83 · ce16c83
1 parent d258495
commit ce16c83
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 8 deletions.
diff --git a/src/frontend/src/optimizer/plan_node/logical_cte_ref.rs b/src/frontend/src/optimizer/plan_node/logical_cte_ref.rs
@@ -65,25 +65,25 @@ impl PredicatePushdown for LogicalCteRef {
         _predicate: Condition,
         _ctx: &mut PredicatePushdownContext,
     ) -> PlanRef {
-        self.clone().into()
+       unimplemented!("recursive CTE not supported for predicate_pushdown of LogicalCteRef")
     }
 }
 
 impl ToBatch for LogicalCteRef {
     fn to_batch(&self) -> Result<PlanRef> {
-        bail_not_implemented!(issue = 15135, "recursive CTE not supported")
+        bail_not_implemented!(issue = 15135, "recursive CTE not supported for to_batch of LogicalCteRef")
     }
 }
 
 impl ToStream for LogicalCteRef {
     fn to_stream(&self, _ctx: &mut ToStreamContext) -> Result<PlanRef> {
-        bail_not_implemented!(issue = 15135, "recursive CTE not supported")
+        bail_not_implemented!(issue = 15135, "recursive CTE not supported for to_stream of LogicalCteRef")
     }
 
     fn logical_rewrite_for_stream(
         &self,
         _ctx: &mut RewriteStreamContext,
     ) -> Result<(PlanRef, ColIndexMapping)> {
-        bail_not_implemented!(issue = 15135, "recursive CTE not supported")
+        bail_not_implemented!(issue = 15135, "recursive CTE not supported for logical_rewrite_for_stream of LogicalCteRef")
     }
 }
diff --git a/src/frontend/src/optimizer/plan_node/logical_recursive_union.rs b/src/frontend/src/optimizer/plan_node/logical_recursive_union.rs
@@ -100,25 +100,25 @@ impl PredicatePushdown for LogicalRecursiveUnion {
         _predicate: Condition,
         _ctx: &mut PredicatePushdownContext,
     ) -> PlanRef {
-        self.clone().into()
+        unimplemented!("recursive CTE not supported for predicate_pushdown of LogicalRecursiveUnion")
     }
 }
 
 impl ToBatch for LogicalRecursiveUnion {
     fn to_batch(&self) -> Result<PlanRef> {
-        bail_not_implemented!(issue = 15135, "recursive CTE not supported")
+        bail_not_implemented!(issue = 15135, "recursive CTE not supported for to_batch of LogicalRecursiveUnion")
     }
 }
 
 impl ToStream for LogicalRecursiveUnion {
     fn to_stream(&self, _ctx: &mut ToStreamContext) -> Result<PlanRef> {
-        bail_not_implemented!(issue = 15135, "recursive CTE not supported")
+        bail_not_implemented!(issue = 15135, "recursive CTE not supported for to_stream of LogicalRecursiveUnion")
     }
 
     fn logical_rewrite_for_stream(
         &self,
         _ctx: &mut RewriteStreamContext,
     ) -> Result<(PlanRef, ColIndexMapping)> {
-        bail_not_implemented!(issue = 15135, "recursive CTE not supported")
+        bail_not_implemented!(issue = 15135, "recursive CTE not supported for logical_rewrite_for_stream of LogicalRecursiveUnion")
     }
 }