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 i
Sent from Mail for Windows 10
