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 8843ee001333681c9d900dfe37e18b3f5522669d Author: Sasaki Toru <[email protected]> AuthorDate: Fri May 2 23:54:46 2025 +0900 Fix doc issues of DataSink in DataStream API * broken url to StatefulSinkWriter * used wrong image in SupportPreCommitTopology section --- docs/content/docs/dev/datastream/sinks.md | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/docs/content/docs/dev/datastream/sinks.md b/docs/content/docs/dev/datastream/sinks.md index 8270fb751fd..6e280d085a1 100644 --- a/docs/content/docs/dev/datastream/sinks.md +++ b/docs/content/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.
