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 <shivam7.iit...@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.
