fapaul commented on a change in pull request #17351:
URL: https://github.com/apache/flink/pull/17351#discussion_r716639035
##########
File path:
flink-core/src/main/java/org/apache/flink/api/connector/sink/SinkWriter.java
##########
@@ -63,6 +63,9 @@ default void writeWatermark(Watermark watermark) throws
IOException, Interrupted
*
* <p>This will be called before we checkpoint the Writer's state in
Streaming execution mode.
*
+ * <p>In case the sink implements a 1-phase commit protocol, this method
should trigger the
Review comment:
No worries, your suggestion definitely provides more information about
the committer writer relation.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
