This is an automated email from the ASF dual-hosted git repository. leesf pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/hudi.git
The following commit(s) were added to refs/heads/master by this push: new e0a5e0d [HUDI-1000] Fix incremental query for COW non-partitioned table with no data (#1708) e0a5e0d is described below commit e0a5e0d3435acc5f01812aa46d96cc7d5eb65860 Author: hj2016 <hj3245...@163.com> AuthorDate: Mon Jun 8 15:34:42 2020 +0800 [HUDI-1000] Fix incremental query for COW non-partitioned table with no data (#1708) --- .../src/main/java/org/apache/hudi/hadoop/HoodieParquetInputFormat.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 6b0ecb9..5a10f3c 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