akalash commented on a change in pull request #17929:
URL: https://github.com/apache/flink/pull/17929#discussion_r759340123
##########
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/BoundedMultiInput.java
##########
@@ -19,13 +19,25 @@
import org.apache.flink.annotation.PublicEvolving;
-/** Interface for the multi-input operators that can process EndOfInput event.
*/
+/**
+ * Interface for multi-input operators that need to be notified about the
logical/semantical end of
+ * input.
+ *
+ * <p><b>WARNING:</b> It is not safe to use this method to commit any
transactions or other side
+ * effects! You can use this method to e.g. flush data buffered for the given
input or implement an
+ * ordered reading from multiple inputs via {@link InputSelectable}.
Review comment:
Wouldn't it be better to put this paragraph before `endInput` method?
--
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]
