From e78681445fa4430fe3a9ad26aa5d2c8c1ceb4cb1 Mon Sep 17 00:00:00 2001 From: zhangyuang Date: Fri, 20 May 2022 17:05:54 +0800 Subject: [PATCH] [HUDI-4129] Initializes a new fs view for WriteProfile#reload --- .../apache/hudi/sink/partitioner/profile/WriteProfile.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) 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();