recursive cte be part

Author: BiteTheDDDDt

fe/fe-core/src/main/java/org/apache/doris/qe/SessionVariable.java

@@ -794,6 +794,8 @@ public class SessionVariable implements Serializable, Writable {
 
     public static final String READ_HIVE_JSON_IN_ONE_COLUMN = "read_hive_json_in_one_column";
 
+    public static final String CTE_MAX_RECURSION_DEPTH = "cte_max_recursion_depth";
+
     /**
      * Inserting overwrite for auto partition table allows creating partition for
      * datas which cannot find partition to overwrite.
@@ -1012,6 +1014,11 @@ public static double getHotValueThreshold() {
     }, varType = VariableAnnotation.DEPRECATED)
     public int minScanSchedulerConcurrency = 0;
 
+    @VariableMgr.VarAttr(name = CTE_MAX_RECURSION_DEPTH, needForward = true, description = {
+            "CTE递归的最大深度，默认值100",
+            "The maximum depth of CTE recursion. Default is 100" })
+    public int cteMaxRecursionDepth = 100;
+
     // By default, the number of Limit items after OrderBy is changed from 65535 items
     // before v1.2.0 (not included), to return all items by default
     @VariableMgr.VarAttr(name = DEFAULT_ORDER_BY_LIMIT, affectQueryResultInExecution = true)
@@ -4883,7 +4890,7 @@ public TQueryOptions toThrift() {
         tResult.setInvertedIndexSkipThreshold(invertedIndexSkipThreshold);
 
         tResult.setInvertedIndexCompatibleRead(invertedIndexCompatibleRead);
-
+        tResult.setCteMaxRecursionDepth(cteMaxRecursionDepth);
         tResult.setEnableParallelScan(enableParallelScan);
         tResult.setParallelScanMaxScannersCount(parallelScanMaxScannersCount);
         tResult.setParallelScanMinRowsPerScanner(parallelScanMinRowsPerScanner);

gensrc/thrift/PaloInternalService.thrift

@@ -410,6 +410,7 @@ struct TQueryOptions {
 
   175: optional bool enable_fuzzy_blockable_task = false;
   176: optional list<i32> shuffled_agg_ids;
+  177: optional i32 cte_max_recursion_depth;
 
   177: optional bool enable_extended_regex = false;
   // Target file size in bytes for Iceberg write operations