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.
---