branch-3.0: [fix](mtmv)Release snapshots to avoid keeping references …

…in MTMVTask #47149 (#47258) Cherry-picked from #47149 Co-authored-by: zhangdong <[email protected]>
apache · Feb 11, 2025 · 95ad500 · 95ad500
1 parent 3a7d873
commit 95ad500
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/fe/fe-core/src/main/java/org/apache/doris/job/extensions/mtmv/MTMVTask.java b/fe/fe-core/src/main/java/org/apache/doris/job/extensions/mtmv/MTMVTask.java
@@ -149,7 +149,7 @@ public enum MTMVTaskRefreshMode {
     private StmtExecutor executor;
     private Map<String, MTMVRefreshPartitionSnapshot> partitionSnapshots;
 
-    private final Map<MvccTableInfo, MvccSnapshot> snapshots = Maps.newHashMap();
+    private Map<MvccTableInfo, MvccSnapshot> snapshots = Maps.newHashMap();
 
     public MTMVTask() {
     }
@@ -491,6 +491,9 @@ protected void closeOrReleaseResources() {
         if (null != partitionSnapshots) {
             partitionSnapshots = null;
         }
+        if (null != snapshots) {
+            snapshots = null;
+        }
     }
 
     private Map<TableIf, String> getIncrementalTableMap() throws AnalysisException {