Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/5317#discussion_r166921740
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/SequenceNumberingViewReader.java
---
@@ -77,14 +78,35 @@ void requestSubpartitionView(
}
}
- InputChannelID getReceiverId() {
+ @Override
+ public void addCredit(int creditDeltas) {
+ }
+
+ @Override
+ public void setRegisteredAsAvailable(boolean isRegisteredAvailable) {
+ }
+
+ @Override
+ public boolean isRegisteredAsAvailable() {
+ return false;
--- End diff --
Why this is not implemented?
---