@Override
    default void notifyCheckpointComplete(long checkpointId) throws Exception {
    }
We have an empty default implementation here because most dialects do not have to implement
the method.

@see CheckpointListener#notifyCheckpointComplete(long)
inlong-sort/sort-flink/cdc-base/src/main/java/org/apache/inlong/sort/cdc/base/dialect/DataSourceDialect.java