From 10e8c518855d9a10b507392588ede2a85de768ad Mon Sep 17 00:00:00 2001 From: FocusComputing Date: Mon, 31 Oct 2022 15:25:15 +0800 Subject: [PATCH] [MINOR] Fix doc of org.apache.hudi.sink.meta.CkpMetadata#bootstrap (#7048) Co-authored-by: xiaoxingstack --- .../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. */