[GitHub] flink pull request #6071: [FLINK-3952][runtine] Upgrade to Netty 4.1

[pnowojski]

Github user pnowojski commented on a diff in the pull request:

    https://github.com/apache/flink/pull/6071#discussion_r194770093
  
    --- Diff: 
flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/ChunkedByteBuf.java
 ---
    @@ -88,6 +102,16 @@ public ByteBuf readChunk(ChannelHandlerContext ctx) 
throws Exception {
                }
        }
     
    +   @Override
    +   public long length() {
    +           return length;
    +   }
    +
    +   @Override
    +   public long progress() {
    +           return length - buf.readableBytes();
    --- End diff --
    
    changed to `return buf.readerIndex()` since progress is not well defined.


---