Flink queryable state - io.netty4 errors

Posted by shivam7 on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Flink-queryable-state-io-netty4-errors-tp28592.html

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.