Flink queryable state - io.netty4 errors

[shivam7]

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 i

 

 

Sent from Mail for Windows 10