Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6071#discussion_r194652733
--- 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 --
If the length is not know, then I think it would be better to return
something like `buf.readerIndex - initialReaderIndex`.
---
