This is an automated email from the ASF dual-hosted git repository.
yuzelin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git
The following commit(s) were added to refs/heads/master by this push:
new 1bb1af94a1 [core] Add manifest file name in ManifestFileBlockMerger
exception message for troubleshooting (#9432)
1bb1af94a1 is described below
commit 1bb1af94a19f44a870991006cbaaa3ee140890e8
Author: yuzelin <[email protected]>
AuthorDate: Fri Aug 28 11:53:24 2026 +0800
[core] Add manifest file name in ManifestFileBlockMerger exception message
for troubleshooting (#9432)
---
.../java/org/apache/paimon/operation/ManifestFileBlockMerger.java | 4 ++++
.../org/apache/paimon/operation/ManifestRewriteCleanupTest.java | 6 +++++-
2 files changed, 9 insertions(+), 1 deletion(-)
diff --git
a/paimon-core/src/main/java/org/apache/paimon/operation/ManifestFileBlockMerger.java
b/paimon-core/src/main/java/org/apache/paimon/operation/ManifestFileBlockMerger.java
index 4f1bb922ab..a363112215 100644
---
a/paimon-core/src/main/java/org/apache/paimon/operation/ManifestFileBlockMerger.java
+++
b/paimon-core/src/main/java/org/apache/paimon/operation/ManifestFileBlockMerger.java
@@ -483,6 +483,10 @@ final class ManifestFileBlockMerger {
emittedDeletes,
metadata,
encodedRecordsCompatible);
+ } catch (Throwable t) {
+ throw new RuntimeException(
+ "Failed to rewrite manifest file '" +
manifest.fileName() + "'.",
+ t);
}
}
}
diff --git
a/paimon-core/src/test/java/org/apache/paimon/operation/ManifestRewriteCleanupTest.java
b/paimon-core/src/test/java/org/apache/paimon/operation/ManifestRewriteCleanupTest.java
index 31c6940301..cc160d8589 100644
---
a/paimon-core/src/test/java/org/apache/paimon/operation/ManifestRewriteCleanupTest.java
+++
b/paimon-core/src/test/java/org/apache/paimon/operation/ManifestRewriteCleanupTest.java
@@ -43,6 +43,7 @@ import org.apache.paimon.manifest.ProjectedManifestEntry;
import org.apache.paimon.options.Options;
import org.apache.paimon.schema.SchemaManager;
import org.apache.paimon.stats.StatsTestUtils;
+import org.apache.paimon.testutils.assertj.PaimonAssertions;
import org.apache.paimon.types.DataTypes;
import org.apache.paimon.types.RowType;
import org.apache.paimon.utils.FileStorePathFactory;
@@ -294,7 +295,10 @@ class ManifestRewriteCleanupTest extends
ManifestFileMetaTestBase {
PARTITION_TYPE,
1));
- assertThat(thrown).isSameAs(primaryFailure);
+ assertThat(thrown)
+ .satisfies(
+ PaimonAssertions.anyCauseMatches(
+ primaryFailure.getClass(),
primaryFailure.getMessage()));
assertThat(thrown.getSuppressed())
.extracting(Throwable::getMessage)
.containsExactly("delete failure 1");