remove cleanUpCTE

Author: shizy818

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/QueryExecution.java

@@ -47,7 +47,6 @@
 import org.apache.iotdb.db.queryengine.plan.planner.plan.FragmentInstance;
 import org.apache.iotdb.db.queryengine.plan.planner.plan.LogicalQueryPlan;
 import org.apache.iotdb.db.queryengine.plan.planner.plan.node.PlanNodeUtil;
-import org.apache.iotdb.db.queryengine.plan.relational.planner.CteMaterializer;
 import org.apache.iotdb.db.queryengine.plan.scheduler.IScheduler;
 import org.apache.iotdb.db.utils.SetThreadName;
 import org.apache.iotdb.mpp.rpc.thrift.TFragmentInstanceId;
@@ -350,9 +349,6 @@ private void releaseResource() {
       resultHandle.close();
       cleanUpResultHandle();
     }
-    if (getSQLDialect().equals(IClientSession.SqlDialect.TABLE) && !context.isSubquery()) {
-      CteMaterializer.getInstance().cleanUpCTE(context);
-    }
   }
 
   private void cleanUpResultHandle() {
@@ -396,9 +392,6 @@ private void releaseResource(Throwable t) {
       }
       cleanUpResultHandle();
     }
-    if (getSQLDialect().equals(IClientSession.SqlDialect.TABLE) && !context.isSubquery()) {
-      CteMaterializer.getInstance().cleanUpCTE(context);
-    }
   }
 
   /**

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/CteMaterializer.java

@@ -39,7 +39,6 @@
 import org.apache.iotdb.db.queryengine.plan.planner.plan.DistributedQueryPlan;
 import org.apache.iotdb.db.queryengine.plan.planner.plan.FragmentInstance;
 import org.apache.iotdb.db.queryengine.plan.relational.analyzer.Analysis;
-import org.apache.iotdb.db.queryengine.plan.relational.analyzer.NodeRef;
 import org.apache.iotdb.db.queryengine.plan.relational.metadata.ColumnSchema;
 import org.apache.iotdb.db.queryengine.plan.relational.metadata.TableSchema;
 import org.apache.iotdb.db.queryengine.plan.relational.sql.ast.Identifier;
@@ -99,16 +98,6 @@ public void materializeCTE(Analysis analysis, MPPQueryContext context) {
             });
   }
 
-  public void cleanUpCTE(MPPQueryContext context) {
-    Map<NodeRef<Table>, Query> cteQueries = context.getCteQueries();
-    cteQueries.values().stream()
-        .map(Query::getCteDataStore)
-        .filter(java.util.Objects::nonNull)
-        .distinct()
-        .forEach(CteDataStore::clear);
-    cteQueries.clear();
-  }
-
   public CteDataStore fetchCteQueryResult(
       MPPQueryContext context, Table table, Query query, With with) {
     final long queryId = sessionManager.requestQueryId();

iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/planner/CteSubqueryTest.java

@@ -83,7 +83,7 @@ public void testCteSubquery() throws IoTDBException {
     mockExecuteForTableModel();
 
     String sql =
-        "with cte1 as (select time, s1 from table1) select s1 from table1 "
+        "with cte1 as (select time, s2 from table1) select s1 from table1 "
             + "where s1 = (select s2 from cte1)";
 
     LogicalQueryPlan logicalQueryPlan = planTester.createPlan(sql);