Flink: Fix duplicate data with upsert writer in case of aborted checkpoints #27146
Job | Run time |
---|---|
9m 54s | |
11m 53s | |
9m 53s | |
3m 24s | |
11m 49s | |
8m 31s | |
3m 30s | |
10m 42s | |
3m 22s | |
1h 12m 58s |
Job | Run time |
---|---|
9m 54s | |
11m 53s | |
9m 53s | |
3m 24s | |
11m 49s | |
8m 31s | |
3m 30s | |
10m 42s | |
3m 22s | |
1h 12m 58s |