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 it.

[Yun Tang]

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 <[hidden email]>
Sent: Sunday, July 7, 2019 17:35
To: [hidden email]
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.