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 w
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 _