fix: release memory occupied by CteDataStore

Author: shizy818

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

@@ -165,6 +165,7 @@ public CteDataStore fetchCteQueryResult(Table table, Query query, MPPQueryContex
                 "!!! Failed to materialize CTE. The main query falls back to INLINE mode !!!");
           }
           context.releaseMemoryReservedForFrontEnd(cteDataStore.getCachedBytes());
+          cteDataStore.clear();
           return null;
         }
       }
@@ -179,6 +180,7 @@ public CteDataStore fetchCteQueryResult(Table table, Query query, MPPQueryContex
     } catch (final Throwable throwable) {
       if (cteDataStore != null) {
         context.releaseMemoryReservedForFrontEnd(cteDataStore.getCachedBytes());
+        cteDataStore.clear();
       }
       t = throwable;
     } finally {

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/cte/CteDataStore.java

@@ -56,9 +56,6 @@ public boolean addTsBlock(TsBlock tsBlock) {
     int rows = tsBlock.getPositionCount();
     if (bytesSize + cachedBytes >= iotConfig.getCteBufferSize()
         || rows + cachedRows >= iotConfig.getMaxRowsInCteBuffer()) {
-      cachedData.clear();
-      cachedBytes = 0;
-      cachedRows = 0;
       return false;
     }
     cachedData.add(tsBlock);
@@ -70,6 +67,7 @@ public boolean addTsBlock(TsBlock tsBlock) {
   public void clear() {
     cachedData.clear();
     cachedBytes = 0L;
+    cachedRows = 0;
   }
 
   public List<TsBlock> getCachedData() {