Skip to content

[FLINK-38450][iceberg] Fix duplicate records when schema change splits writes within a checkpoint #2445

[FLINK-38450][iceberg] Fix duplicate records when schema change splits writes within a checkpoint

[FLINK-38450][iceberg] Fix duplicate records when schema change splits writes within a checkpoint #2445

Job Run time
1h 3m 23s
4m 24s
1h 3m 6s
13m 22s
13m 12s
47m 17s
1h 0m 3s
43m 1s
46m 58s
28m 30s
47m 40s
1h 31m 13s
57m 59s
1h 21m 48s
35m 18s
1h 3m 1s
1h 31m 53s
41m 3s
1h 20m 28s
1h 19m 4s
38m 53s
1h 3m 6s
28m 30s
57m 59s
47m 17s
1h 0m 3s
13m 12s
13m 22s
41m 3s
47m 40s
43m 1s
4m 24s
1h 3m 1s
1h 3m 23s
46m 58s
35m 18s
1d 4h 39m 53s