You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by gu...@apache.org on 2025/05/06 09:14:09 UTC
(flink) 02/02: Fix Chinese doc issues of DataSink in DataStream API
This is an automated email from the ASF dual-hosted git repository.
guoweijie pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit e040a67f3918766bb6fb5b375a09ec58af5c6ca4
Author: Sasaki Toru <To...@nttdata.com>
AuthorDate: Sat May 3 00:04:13 2025 +0900
Fix Chinese doc issues of DataSink in DataStream API
* broken url to StatefulSinkWriter
* used wrong image in SupportPreCommitTopology section
---
docs/content.zh/docs/dev/datastream/sinks.md | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/docs/content.zh/docs/dev/datastream/sinks.md b/docs/content.zh/docs/dev/datastream/sinks.md
index 32ca9fa70be..67eaa28960a 100644
--- a/docs/content.zh/docs/dev/datastream/sinks.md
+++ b/docs/content.zh/docs/dev/datastream/sinks.md
@@ -81,7 +81,7 @@ Please check the [Java doc](https://nightlies.apache.org/flink/flink-docs-releas
The {{< gh_link file="flink-core/src/main/java/org/apache/flink/api/connector/sink2/SupportsWriterState.java" name="SupportsWriterState" >}} interface is used to indicate that the sink supports writer state, which means that the sink can be recovered from a failure.
-The `SupportsWriterState` interface requires the `SinkWriter` to implement the {{ gh_link file="flink-core/src/main/java/org/apache/flink/api/connector/sink2/StatefulSinkWriter.java" name="StatefulSinkWriter" >}} interface.
+The `SupportsWriterState` interface requires the `SinkWriter` to implement the {{< gh_link file="flink-core/src/main/java/org/apache/flink/api/connector/sink2/StatefulSinkWriter.java" name="StatefulSinkWriter" >}} interface.
### SupportsCommitter
@@ -111,7 +111,7 @@ In the figure above, user add a `PrePartition` and `PostPartition` operator in t
The following figure shows the operator topology of using {{< gh_link file="flink-runtime/src/main/java/org/apache/flink/streaming/api/connector/sink2/SupportsPreCommitTopology.java" name="SupportsPreCommitTopology" >}}:
-{{< img src="/fig/dev/datastream/SupportsPreWriteTopology.png" class="center" >}}
+{{< img src="/fig/dev/datastream/SupportsPreCommitTopology.png" class="center" >}}
In the figure above, user add a `CollectCommit` operator in the `SupportsPreCommitTopology` topology, and collect all the commit messages from the `SinkWriter` to one subtask, then send to the `Committer` to process them centrally, this can reduce the number of interactions with the server.