lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[HUDI-301] fix path error when update a non-partition MOR table

Browse Source
This commit is contained in:
Wenning Ding
2019-10-10 23:21:00 -07:00
committed by Balaji Varadarajan
parent 12523c379f
commit 1c09f5b055
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
hudi-client/src/main/java/org/apache/hudi/io/HoodieAppendHandle.java
View File

@@ -140,7 +140,8 @@ public class HoodieAppendHandle<T extends HoodieRecordPayload> extends HoodieWri
throw new HoodieUpsertException("Failed to initialize HoodieAppendHandle for FileId: " + fileId + " on commit " throw new HoodieUpsertException("Failed to initialize HoodieAppendHandle for FileId: " + fileId + " on commit "
+ instantTime + " on HDFS path " + hoodieTable.getMetaClient().getBasePath() + partitionPath, e); + instantTime + " on HDFS path " + hoodieTable.getMetaClient().getBasePath() + partitionPath, e);
} }
Path path = new Path(partitionPath, writer.getLogFile().getFileName()); Path path = partitionPath.length() == 0 ? new Path(writer.getLogFile().getFileName())
: new Path(partitionPath, writer.getLogFile().getFileName());
writeStatus.getStat().setPath(path.toString()); writeStatus.getStat().setPath(path.toString());
doInit = false; doInit = false;
} }