lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[HUDI-2984] Implement #close for AbstractTableFileSystemView (#4285)

Browse Source
This commit is contained in:
Danny Chan
2021-12-11 16:19:10 +08:00
committed by GitHub
parent b5f05fd153
commit 8dd0444ef9
4 changed files with 25 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
hudi-flink/src/main/java/org/apache/hudi/sink/partitioner/profile/WriteProfile.java
View File

@@ -249,7 +249,7 @@ public class WriteProfile {
return;
}
this.metaClient.reloadActiveTimeline();
this.fsView = getFileSystemView();
this.fsView.sync();
recordProfile();
cleanMetadataCache(this.metaClient.getCommitsTimeline().filterCompletedInstants().getInstants());
this.smallFilesMap.clear();