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 <[email protected]>
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