lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[HUDI-2994] Add judgement to existed partitionPath in the catch code block for HU… (#4294)

Browse Source 
* [HUDI-2994] Add judgement to existed partition path in the catch code block for HUDI-2743

Co-authored-by: wangminchao <wangminchao@asinking.com>
This commit is contained in:
WangMinChao
2021-12-13 20:41:03 +08:00
committed by GitHub
parent dd96129191
commit 46de25d5fd
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
hudi-common/src/main/java/org/apache/hudi/common/table/view/AbstractTableFileSystemView.java
View File

@@ -336,9 +336,11 @@ public abstract class AbstractTableFileSystemView implements SyncableFileSystemV
if (!metaClient.getFs().exists(partitionPath)) { if (!metaClient.getFs().exists(partitionPath)) {
metaClient.getFs().mkdirs(partitionPath); metaClient.getFs().mkdirs(partitionPath);
return new FileStatus[0]; 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));
} }
/** /**