diff --git a/hudi-client/src/main/java/org/apache/hudi/io/HoodieAppendHandle.java b/hudi-client/src/main/java/org/apache/hudi/io/HoodieAppendHandle.java index 13ab1d0bf..7906aa2a5 100644 --- a/hudi-client/src/main/java/org/apache/hudi/io/HoodieAppendHandle.java +++ b/hudi-client/src/main/java/org/apache/hudi/io/HoodieAppendHandle.java @@ -140,7 +140,8 @@ public class HoodieAppendHandle extends HoodieWri throw new HoodieUpsertException("Failed to initialize HoodieAppendHandle for FileId: " + fileId + " on commit " + 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()); doInit = false; }