Flink queryable state - io.netty4 errors

[Shivam Dubey <sh...@gmail.com>]

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.

Re: Flink queryable state - io.netty4 errors

[Yun Tang <my...@live.com>]

Hi Shivam

Did this reproduce each time? Would you please share the full stack trace when you get this exception. Moreover, task manager log of that value state is also very welcome.

Best
Yun Tang
________________________________
From: Shivam Dubey <sh...@gmail.com>
Sent: Sunday, July 7, 2019 17:35
To: user@flink.apache.org
Subject: Flink queryable state - io.netty4 errors


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.