AHeise commented on a change in pull request #13228:
URL: https://github.com/apache/flink/pull/13228#discussion_r492570334
##########
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/BufferAvailabilityListener.java
##########
@@ -34,11 +30,8 @@
void notifyDataAvailable();
/**
- * Allows the listener to react to a priority event before it is added
to the outgoing buffer queue.
- *
- * @return true if the event has been fully processed and should not be
added to the buffer queue.
+ * Called when the first priority event is added to the head of the
buffer queue.
*/
- default boolean notifyPriorityEvent(BufferConsumer eventBufferConsumer)
throws IOException {
- return false;
+ default void notifyPriorityEvent() {
Review comment:
Added a few thoughts. Let me know if it makes things clearer.
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
