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 process to
resume from where it left off after restarting? Alternatively, could you
share some best practices for effectively handling these situations?

PS : Here flink source is the File

Thanks and regards,
Arjun

Reply via email to