env { parallelism = 1 job.mode = "STREAMING" checkpoint.interval = 10000 } source { MySQL-CDC { plugin_output = "to-ck-data" base-url = "jdbc:mysql://xx.xx.xx.xx:3306 ...

We cache tombstone time to avoid fetching it from RocksDB on each read. This is valid for colocated tables, since their tombstone only updates during DROP TABLE. However, Truncate on a system table ...