From c1f52afbb6a49d25255d2ad4433da9c3caa2913f Mon Sep 17 00:00:00 2001
From: junhangis <xieweiping@xfusion.com>
Date: Sun, 7 Aug 2022 00:02:43 +0800
Subject: [PATCH] Rownum can not be shipped

---
 src/gausskernel/optimizer/plan/streamwalker.cpp | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

diff --git a/src/gausskernel/optimizer/plan/streamwalker.cpp b/src/gausskernel/optimizer/plan/streamwalker.cpp
index e28b35271..9f3951282 100644
--- a/src/gausskernel/optimizer/plan/streamwalker.cpp
+++ b/src/gausskernel/optimizer/plan/streamwalker.cpp
@@ -928,7 +928,13 @@ static bool contain_unsupport_expression(Node* expr, void* context)
                 }
             }
         } break;
-
+	case T_Rownum: {
+            sprintf_rc = sprintf_s(u_sess->opt_cxt.not_shipping_info->not_shipping_reason,
+                NOTPLANSHIPPING_LENGTH,
+                "Rownum can not be shipped.");
+            securec_check_ss_c(sprintf_rc, "\0", "\0");
+            cxt->current_shippable = false;
+        } break;
         default:
             /* Record return type is not stream supported */
             if (exprType(expr) == RECORDOID) {