From 05c916be042f486e8a2dd089fe111cb3d95f594e Mon Sep 17 00:00:00 2001 From: xiaoxingstack Date: Mon, 24 Oct 2022 18:18:24 +0800 Subject: [PATCH] [HUDI-5086] Fix doc of org.apache.hudi.sink.meta.CkpMetadata#bootstrap --- .../src/main/java/org/apache/hudi/sink/meta/CkpMetadata.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/meta/CkpMetadata.java b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/meta/CkpMetadata.java index 6895b2a0c63da..c20b263fa36da 100644 --- a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/meta/CkpMetadata.java +++ b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/meta/CkpMetadata.java @@ -90,7 +90,7 @@ public void close() { // ------------------------------------------------------------------------- /** - * Initialize the message bus, would clean all the messages and publish the last pending instant. + * Initialize the message bus, would clean all the messages * *

This expects to be called by the driver. */