From e0a5e0d3435acc5f01812aa46d96cc7d5eb65860 Mon Sep 17 00:00:00 2001 From: hj2016 Date: Mon, 8 Jun 2020 15:34:42 +0800 Subject: [PATCH] [HUDI-1000] Fix incremental query for COW non-partitioned table with no data (#1708) --- .../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 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