Hi,
When restarting a Flink job, Flink will start the job with an empty state,
because this is a new job.
This is not a special for CUMULATE window, but for all Flink jobs.
If you want to restore a Flink job from a state/savepoint, you have to
specify the savepoint path, see [1].
Best,
Jark
[1]:
https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/dev/table/sqlclient/#start-a-sql-job-from-a-savepoint
On Sat, 8 May 2021 at 13:30, Kurt Young wrote:
> Hi, please use user mailing list only to discuss these issues.
>
> Best,
> Kurt
>
>
> On Sat, May 8, 2021 at 1:05 PM 1095193...@qq.com <1095193...@qq.com>
> 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
>> --
>> 1095193...@qq.com
>>
>
