Flink queryable state - io.netty4 errors

[Shivam Dubey]

I am using Flink queryable state client to read a dummy valuestate I
created.

The code is quite simple, just created a stream out of a kafka topic, keys
it as

                inputStream.keyBy(value -> 0L).map(new
mapFucntion()).print()

Withing the mapFunction I create a value state, and declare it as queryable.

Then I try to read it from queryable state client.

While I do,

ValueState<Long> value = returnedCompletableFuture.get();

I am getting errors like-

                Java.lang.IndexOutOfBoundException: readerIndex(0) +
writerIndex(4) is greater than writeIndex(0)

                Caused at some netty4.io.AbstractBufByte





I am really struggling to have this simple queryable client running and
have found nothing over the internet to resolve it.