diff --git a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/partitioner/profile/WriteProfile.java b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/partitioner/profile/WriteProfile.java
index fdb8152b0057..db13a6c2ae58 100644
--- a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/partitioner/profile/WriteProfile.java
+++ b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/partitioner/profile/WriteProfile.java
@@ -256,7 +256,11 @@ public synchronized void reload(long checkpointId) {
       return;
     }
     this.metaClient.reloadActiveTimeline();
-    this.fsView.sync();
+    // release the old fs view and create a new one
+    SyncableFileSystemView oldFsView = this.fsView;
+    this.fsView = getFileSystemView();
+    oldFsView.close();
+
     recordProfile();
     cleanMetadataCache(this.metaClient.getCommitsTimeline().filterCompletedInstants().getInstants());
     this.smallFilesMap.clear();