@Override
    public void stop() {
        if (instanceName != null) {
            DatabaseHistoryUtil.removeHistory(instanceName);
        }
        listener.stopped();
    }
Determine whether the {@link FlinkDatabaseSchemaHistory} is compatible with the specified
state.
inlong-sort/sort-flink/cdc-base/src/main/java/org/apache/inlong/sort/cdc/base/debezium/internal/FlinkDatabaseSchemaHistory.java