lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[HUDI-1000] Fix incremental query for COW non-partitioned table with no data (#1708)

Browse Source
This commit is contained in:
hj2016
2020-06-08 15:34:42 +08:00
committed by GitHub
parent e9cab67b80
commit e0a5e0d343
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/HoodieParquetInputFormat.java
View File

@@ -183,7 +183,7 @@ public class HoodieParquetInputFormat extends MapredParquetInputFormat implement
return null; return null;
} }
String incrementalInputPaths = partitionsToList.stream() 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 -> { .filter(s -> {
/* /*
* Ensure to return only results from the original input path that has incremental changes * Ensure to return only results from the original input path that has incremental changes