diff --git a/paimon-core/src/main/java/org/apache/paimon/operation/FileStoreCommitImpl.java b/paimon-core/src/main/java/org/apache/paimon/operation/FileStoreCommitImpl.java index ee672f4ac6d6..de4cff9d1e7f 100644 --- a/paimon-core/src/main/java/org/apache/paimon/operation/FileStoreCommitImpl.java +++ b/paimon-core/src/main/java/org/apache/paimon/operation/FileStoreCommitImpl.java @@ -1318,7 +1318,9 @@ private void assertNoDelete( "You are writing data to expired partitions, and you can filter this data to avoid job failover." + " Otherwise, continuous expired records will cause the job to failover restart continuously." + " Expired partitions are: " - + expiredPartitions); + + expiredPartitions + + " ,tableName: " + + tableName); } } conflictHandler.accept(e); diff --git a/paimon-core/src/test/java/org/apache/paimon/operation/PartitionExpireTest.java b/paimon-core/src/test/java/org/apache/paimon/operation/PartitionExpireTest.java index 901a93737bd4..c1c975730027 100644 --- a/paimon-core/src/test/java/org/apache/paimon/operation/PartitionExpireTest.java +++ b/paimon-core/src/test/java/org/apache/paimon/operation/PartitionExpireTest.java @@ -338,7 +338,8 @@ public void testDeleteExpiredPartition() throws Exception { .hasMessage( "You are writing data to expired partitions, and you can filter " + "this data to avoid job failover. Otherwise, continuous expired records will cause the" - + " job to failover restart continuously. Expired partitions are: [20230101]"); + + " job to failover restart continuously. Expired partitions are: [20230101] ,tableName: " + + table.name()); } private List read() throws IOException {