From 1da672925d8541a65ab43cab995425c0c11b6b62 Mon Sep 17 00:00:00 2001 From: Thinking <744417972@qq.com> Date: Tue, 24 Dec 2019 13:19:57 +0800 Subject: [PATCH] - Fix Error: java.lang.IllegalArgumentException: Can not create a Path from an empty string same link in https://github.com/apache/incubator-hudi/pull/771 this time is in HoodieCopyOnWrite deleteFilesFunc method --- .../main/java/org/apache/hudi/table/HoodieCopyOnWriteTable.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/hudi-client/src/main/java/org/apache/hudi/table/HoodieCopyOnWriteTable.java b/hudi-client/src/main/java/org/apache/hudi/table/HoodieCopyOnWriteTable.java index 2a6ce86776608..ed9c65dccee14 100644 --- a/hudi-client/src/main/java/org/apache/hudi/table/HoodieCopyOnWriteTable.java +++ b/hudi-client/src/main/java/org/apache/hudi/table/HoodieCopyOnWriteTable.java @@ -109,7 +109,7 @@ private static PairFlatMapFunction>, String, Par Tuple2 partitionDelFileTuple = iter.next(); String partitionPath = partitionDelFileTuple._1(); String delFileName = partitionDelFileTuple._2(); - Path deletePath = new Path(new Path(basePath, partitionPath), delFileName); + Path deletePath = FSUtils.getPartitionPath(FSUtils.getPartitionPath(basePath, partitionPath), delFileName); String deletePathStr = deletePath.toString(); Boolean deletedFileResult = deleteFileAndGetResult(fs, deletePathStr); if (!partitionCleanStatMap.containsKey(partitionPath)) {