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 <[email protected]> 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) {
