Hi, forideal
I also encountered this problem and opened an issue[1], you can have a look.
Best,
Leonard
[1] https://issues.apache.org/jira/browse/FLINK-22472
> 在 2021年5月7日，20:31，forideal 写道：
>
> I found the reason：
>
>Late data processing: The record will be written into its partition
Hi My friends:
I use FlieSystem in Flink SQL, and I found that my success file was
submitted late, probably dozens of minutes late.
Here I provide some information：
1.Flink version is 1.11.1.
2.Source DDL
create table test （
`timestamp bigint`,
event_time as
