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

Reply via email to