Skip to content

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

[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 #57

Job Run time
3m 46s
25m 53s
26m 8s
11m 10s
4m 56s
11m 40s
4m 53s
7m 41s
6m 41s
30m 17s
30m 36s
29m 48s
30m 11s
30m 7s
21m 57s
35m 42s
33m 59s
37m 59s
6m 47s
29m 13s
17m 27s
26m 15s
12m 50s
3m 44s
3m 20s
8h 3m 0s