Hi Arjun,
Thanks for your query. Flink is fault tolerant and supports exactly-once
semantics. In your case, the aggregated values can be recovered in case of
a failure or application restart.
You just need to enable checkpointing and configure an appropriate state
backend.
Regards,
Jeyhun
>
> O
Hello team,
I'm relatively new to Flink's window functions, and I've configured a
tumbling window with a 10-minute duration. I'm wondering about the scenario
where the Flink job is restarted or the Flink application goes down. Is
there a mechanism to persist the aggregated values, allowing the pro
