flink-clickhouse-sink
flink-clickhouse-sink copied to clipboard
log loss
In the incremental synchronization phase, MySQL data is synchronized through Flinkcdc and then inserted into the clickhouse. During the synchronization process, restarting MySQL found that some logs were lost in the clickhouse, and there were no logs in the failed log directory. Through printing the log, it was found that the Flink program had already printed out the lost log of CDC synchronization.
This situation may require multiple restarts of MySQL to replicate I have tested more than ten times, especially when there is a high amount of log insertion and frequent loss of logs