diff --git a/hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/HoodieParquetInputFormat.java b/hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/HoodieParquetInputFormat.java index 6b0ecb9b0..5a10f3c99 100644 --- a/hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/HoodieParquetInputFormat.java +++ b/hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/HoodieParquetInputFormat.java @@ -183,7 +183,7 @@ public class HoodieParquetInputFormat extends MapredParquetInputFormat implement return null; } String incrementalInputPaths = partitionsToList.stream() - .map(s -> tableMetaClient.getBasePath() + Path.SEPARATOR + s) + .map(s -> StringUtils.isNullOrEmpty(s) ? tableMetaClient.getBasePath() : tableMetaClient.getBasePath() + Path.SEPARATOR + s) .filter(s -> { /* * Ensure to return only results from the original input path that has incremental changes