Re: How to recovery from last count when using CUMULATE window after restart flink-sql job?

Posted by Kurt Young on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/How-to-recovery-from-last-count-when-using-CUMULATE-window-after-restart-flink-sql-job-tp43577p43578.html

Hi, please use user mailing list only to discuss these issues. 

On Sat, May 8, 2021 at 1:05 PM [hidden email] <[hidden email]> wrote:

Hi

   I have tried cumalate window function in Flink-1.13 sql to accumulate data from Kafka. When I restart a cumulate window sql job,  last count state is not considered and the count state accumulates from 1. Any solutions can help recovery from last count state when restarting Flink-sql job?

Thank you 

---

[hidden email]