[hudi] 22/48: [HUDI-4536] ClusteringOperator causes the NullPointerException when writing with BulkInsertWriterHelper in clustering (#6298)

[co...@apache.org]

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

codope pushed a commit to branch release-0.12.0
in repository https://gitbox.apache.org/repos/asf/hudi.git

commit 9d5d4b9219711760a31a1405a11b448580aac909
Author: Nicholas Jiang <pr...@163.com>
AuthorDate: Thu Aug 4 05:25:24 2022 -0700

    [HUDI-4536] ClusteringOperator causes the NullPointerException when writing with BulkInsertWriterHelper in clustering (#6298)
---
 .../main/java/org/apache/hudi/sink/clustering/ClusteringOperator.java    | 1 +
 1 file changed, 1 insertion(+)

diff --git a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/clustering/ClusteringOperator.java b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/clustering/ClusteringOperator.java
index ca48dcf6cb..31db54b361 100644
--- a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/clustering/ClusteringOperator.java
+++ b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/clustering/ClusteringOperator.java
@@ -233,6 +233,7 @@ public class ClusteringOperator extends TableStreamOperator<ClusteringCommitEven
 
     List<WriteStatus> writeStatuses = this.writerHelper.getWriteStatuses(this.taskID);
     collector.collect(new ClusteringCommitEvent(instantTime, writeStatuses, this.taskID));
+    this.writerHelper = null;
   }
 
   private void initWriterHelper(String clusteringInstantTime) {