Skip to content

[FLINK-36701][cdc-runtime] Add steps to get and emit schemaManager's latest evolvedSchema when SinkDataWriterOperator handles FlushEvent #47

[FLINK-36701][cdc-runtime] Add steps to get and emit schemaManager's latest evolvedSchema when SinkDataWriterOperator handles FlushEvent

[FLINK-36701][cdc-runtime] Add steps to get and emit schemaManager's latest evolvedSchema when SinkDataWriterOperator handles FlushEvent #47

Job Run time
3m 49s
11m 27s
4m 55s
11m 54s
5m 39s
7m 25s
25m 54s
6m 57s
26m 39s
32m 6s
29m 39s
30m 23s
29m 53s
5m 45s
5m 47s
5m 48s
5m 48s
5m 47s
5m 28s
5m 46s
5m 47s
5m 49s
5m 45s
3m 28s
3m 16s
4h 50m 54s