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.