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?


---

Reply via email to