Hi Sandeep,
I don't fully understand the problematic scenario yet. What exactly is the
HA state maintained by Kubernetes in S3?
Queryable state works by asking for the current state of an operator. If
you use asQueryableState, then you create a reducing state which appends
all stream elements. Th
Hello,
Stuck at this time. Any help will be appreciated.
I am able to create a queryable state and also query the state. Everything
works correctly.
KeyedStream, Key> stream = sourceStream.keyBy(t2 -> t2.f0);
stream.asQueryableState("queryableVO");
I deploy this on a Kubernetes cluster with F
