Fix Error: java.lang.IllegalArgumentException: Can not create a Path from an empty string in HoodieCopyOnWrite#deleteFilesFunc (#1126)
same link in https://github.com/apache/incubator-hudi/pull/771 this time is in HoodieCopyOnWrite deleteFilesFunc method
This commit is contained in:
@@ -109,7 +109,7 @@ public class HoodieCopyOnWriteTable<T extends HoodieRecordPayload> extends Hoodi
|
|||||||
Tuple2<String, String> partitionDelFileTuple = iter.next();
|
Tuple2<String, String> partitionDelFileTuple = iter.next();
|
||||||
String partitionPath = partitionDelFileTuple._1();
|
String partitionPath = partitionDelFileTuple._1();
|
||||||
String delFileName = partitionDelFileTuple._2();
|
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();
|
String deletePathStr = deletePath.toString();
|
||||||
Boolean deletedFileResult = deleteFileAndGetResult(fs, deletePathStr);
|
Boolean deletedFileResult = deleteFileAndGetResult(fs, deletePathStr);
|
||||||
if (!partitionCleanStatMap.containsKey(partitionPath)) {
|
if (!partitionCleanStatMap.containsKey(partitionPath)) {
|
||||||
|
|||||||
Reference in New Issue
Block a user