From ce16c831a0f4b9062d4b7f580422510a7f6c7c67 Mon Sep 17 00:00:00 2001
From: Michael Xu <xzhseh@gmail.com>
Date: Mon, 13 May 2024 21:41:56 -0700
Subject: [PATCH] update unimplemented msg for LogicalRecursiveUnion &
 LogicalCteRef

---
 src/frontend/src/optimizer/plan_node/logical_cte_ref.rs   | 8 ++++----
 .../src/optimizer/plan_node/logical_recursive_union.rs    | 8 ++++----
 2 files changed, 8 insertions(+), 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
index 7731844b22e34..45a1215a81133 100644
--- 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
index 424a617a32f0e..0467113b515ed 100644
--- 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")
     }
 }