(paimon) branch master updated: [core] Avoid NPE covers real exceptions (#3585)

[lzljs3620320]

This is an automated email from the ASF dual-hosted git repository.

lzljs3620320 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 3baca1cea [core] Avoid NPE covers real exceptions (#3585)
3baca1cea is described below

commit 3baca1cea72bd27de38e6816496511c0d426d7d5
Author: yuzelin <33053040+yuze...@users.noreply.github.com>
AuthorDate: Mon Jun 24 17:58:11 2024 +0800

    [core] Avoid NPE covers real exceptions (#3585)
---
 .../paimon/mergetree/compact/ChangelogMergeTreeRewriter.java      | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git 
a/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/ChangelogMergeTreeRewriter.java
 
b/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/ChangelogMergeTreeRewriter.java
index 50a7ec3be..56c61d874 100644
--- 
a/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/ChangelogMergeTreeRewriter.java
+++ 
b/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/ChangelogMergeTreeRewriter.java
@@ -165,8 +165,12 @@ public abstract class ChangelogMergeTreeRewriter extends 
MergeTreeCompactRewrite
         }
 
         if (null != collectedExceptions) {
-            compactFileWriter.abort();
-            changelogFileWriter.abort();
+            if (compactFileWriter != null) {
+                compactFileWriter.abort();
+            }
+            if (changelogFileWriter != null) {
+                changelogFileWriter.abort();
+            }
             throw collectedExceptions;
         }