diff --git a/hudi-common/src/main/java/org/apache/hudi/common/table/view/AbstractTableFileSystemView.java b/hudi-common/src/main/java/org/apache/hudi/common/table/view/AbstractTableFileSystemView.java index d946cff95eb53..a626c1b5eba13 100644 --- a/hudi-common/src/main/java/org/apache/hudi/common/table/view/AbstractTableFileSystemView.java +++ b/hudi-common/src/main/java/org/apache/hudi/common/table/view/AbstractTableFileSystemView.java @@ -336,9 +336,11 @@ protected FileStatus[] listPartition(Path partitionPath) throws IOException { if (!metaClient.getFs().exists(partitionPath)) { metaClient.getFs().mkdirs(partitionPath); return new FileStatus[0]; + } else { + // in case the partition path was created by another caller + return metaClient.getFs().listStatus(partitionPath); } } - throw new HoodieIOException(String.format("Failed to list partition path: %s", partitionPath)); } /**