AHeise commented on a change in pull request #17351:
URL: https://github.com/apache/flink/pull/17351#discussion_r716633917
##########
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:
Sorry for being nitty, but I'd like to have the interfaces in good shape.
--
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]
