diff --git a/amoro-format-iceberg/src/main/java/org/apache/amoro/utils/TableFileUtil.java b/amoro-format-iceberg/src/main/java/org/apache/amoro/utils/TableFileUtil.java index 3cba6b3c56..ea972067b9 100644 --- a/amoro-format-iceberg/src/main/java/org/apache/amoro/utils/TableFileUtil.java +++ b/amoro-format-iceberg/src/main/java/org/apache/amoro/utils/TableFileUtil.java @@ -217,7 +217,7 @@ public static String optimizingPosDeleteFileName(String dataFileName, String suf } public static boolean isOptimizingPosDeleteFile(String dataFilePath, String posDeleteFilePath) { - return getFileNameWithoutExt(posDeleteFilePath) + return getFileName(posDeleteFilePath) .startsWith( String.format( "%s-%s", getFileNameWithoutExt(dataFilePath), POS_DELETE_FILE_IDENTIFIER));