[FLINK-35446] Fix NPE when disabling checkpoint file merging but rest…

…ore from merged files
Zakelly · May 24, 2024 · 5a78e68 · 5a78e68
1 parent 54f037f
commit 5a78e68
Showing 1 changed file with 5 additions and 4 deletions.
diff --git a/.../java/org/apache/flink/runtime/checkpoint/filemerging/FileMergingSnapshotManagerBase.java b/.../java/org/apache/flink/runtime/checkpoint/filemerging/FileMergingSnapshotManagerBase.java
@@ -684,10 +684,11 @@ public void restoreStateHandles(
                                         fileHandle.getFilePath(),
                                         path -> {
                                             boolean managedByFileMergingManager =
-                                                    isManagedByFileMergingManager(
-                                                            path,
-                                                            subtaskKey,
-                                                            fileHandle.getScope());
+                                                    fileSystemInitiated
+                                                            && isManagedByFileMergingManager(
+                                                                    path,
+                                                                    subtaskKey,
+                                                                    fileHandle.getScope());
                                             if (managedByFileMergingManager) {
                                                 spaceStat.onPhysicalFileCreate();
                                             }