pnowojski commented on a change in pull request #13465:
URL: https://github.com/apache/flink/pull/13465#discussion_r494408194
##########
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/BlockableInput.java
##########
@@ -26,9 +26,12 @@
/**
* Input, with just basic methods for blocking and resuming consumption. It
can be for example an {@link InputGate}
+ * or a chained source.
*/
@Internal
public interface BlockableInput {
+ void blockConsumption(int inputChannelIdx);
+
void resumeConsumption(int channelIndex) throws IOException;
Review comment:
As discussed offline, we decided to keep it as it is for now.
----------------------------------------------------------------
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:
[email protected]
