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
The following commit(s) were added to refs/heads/master by this push:
new c24f9644a9a [hotfix][javadoc] Fix invalid comments in Committer class
c24f9644a9a is described below
commit c24f9644a9ac731bd00120d8275ebae4d43b5958
Author: Jiaan Geng <[email protected]>
AuthorDate: Thu Apr 2 16:35:25 2026 +0800
[hotfix][javadoc] Fix invalid comments in Committer class
---
.../main/java/org/apache/flink/api/connector/sink2/Committer.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git
a/flink-core/src/main/java/org/apache/flink/api/connector/sink2/Committer.java
b/flink-core/src/main/java/org/apache/flink/api/connector/sink2/Committer.java
index d756f249ddd..3a78559444e 100644
---
a/flink-core/src/main/java/org/apache/flink/api/connector/sink2/Committer.java
+++
b/flink-core/src/main/java/org/apache/flink/api/connector/sink2/Committer.java
@@ -38,9 +38,9 @@ import java.util.Collection;
@Public
public interface Committer<CommT> extends AutoCloseable {
/**
- * Commit the given list of {@link CommT}.
+ * Commit the given collection of {@link CommitRequest}.
*
- * @param committables A list of commit requests staged by the sink writer.
+ * @param committables A collection of commit requests staged by the sink
writer.
* @throws IOException for reasons that may yield a complete restart of
the job.
*/
void commit(Collection<CommitRequest<CommT>> committables)
@@ -49,7 +49,7 @@ public interface Committer<CommT> extends AutoCloseable {
/**
* A request to commit a specific committable.
*
- * @param <CommT>
+ * @param <CommT> The type of information needed to commit the staged data
*/
@Public
interface CommitRequest<CommT> {
