[incubator-paimon] 02/02: [flink] Fix NPE in CommitterOperator

[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/incubator-paimon.git

commit 53ea1b0d76af18a956de0694a302f4ffdcf0f946
Author: Jingsong <jingsongl...@gmail.com>
AuthorDate: Wed Aug 9 11:18:40 2023 +0800

    [flink] Fix NPE in CommitterOperator
---
 .../src/main/java/org/apache/paimon/flink/sink/CommitterOperator.java | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git 
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/CommitterOperator.java
 
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/CommitterOperator.java
index 8efc3220a..66dcd2ce1 100644
--- 
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/CommitterOperator.java
+++ 
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/CommitterOperator.java
@@ -168,7 +168,9 @@ public class CommitterOperator<CommitT, GlobalCommitT> 
extends AbstractStreamOpe
     public void close() throws Exception {
         committablesPerCheckpoint.clear();
         inputs.clear();
-        committer.close();
+        if (committer != null) {
+            committer.close();
+        }
         super.close();
     }