Re: Flink queryable state - io.netty4 errors

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

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

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