This is an automated email from the ASF dual-hosted git repository. pwason pushed a commit to branch release-0.14.0 in repository https://gitbox.apache.org/repos/asf/hudi.git
commit 629ee75fe5f38890d63c479c569596e3a8a3d04c Author: oliver jude <[email protected]> AuthorDate: Mon Sep 4 09:58:55 2023 +0800 [HUDI-6812]Fix bootstrap operator null point exception while lastInstantTime is null (#9599) Co-authored-by: zhuzhengjun <[email protected]> --- .../main/java/org/apache/hudi/sink/bootstrap/BootstrapOperator.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bootstrap/BootstrapOperator.java b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bootstrap/BootstrapOperator.java index 7c9daf4075d..1bdfeb7296b 100644 --- a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bootstrap/BootstrapOperator.java +++ b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bootstrap/BootstrapOperator.java @@ -108,7 +108,9 @@ public class BootstrapOperator<I, O extends HoodieRecord<?>> @Override public void snapshotState(StateSnapshotContext context) throws Exception { lastInstantTime = this.ckpMetadata.lastPendingInstant(); - instantState.update(Collections.singletonList(lastInstantTime)); + if (null != lastInstantTime) { + instantState.update(Collections.singletonList(lastInstantTime)); + } } @Override
