Hi, Falak
>>>Now if I try to query this bucket (state) using a queryable state, then
i don't get the results.
AFAIK, Flink does not have a way to let user query the state of the
`WiindowOperator`. It needs to expose the window operator's internal
implementation, which might be difficult to maintai
Hi, greetings
I am applying window operations on a datastream. Then I apply some
transformation (it could be anything). Let's say I keep the window size to
1 minute and data is coming in a strictly increasing timestamp and let's
say watermark is 1 ms (checkpointing is also enabled). There would be
