private void handleTransactionCompletion(Event event) throws InterruptedException {
        // We are completing the transaction ...
        eventDispatcher.dispatchTransactionCommittedEvent(offsetContext);
        offsetContext.commitTransaction();
        offsetContext.setBinlogThread(-1L);
        skipEvent = false;
        ignoreDmlEventByGtidSource = false;
    }
Handle the supplied event with an {@link QueryEventData} by possibly recording the DDL statements as changes in the
MySQL schemas.

@param event the database change data event to be processed; may not be null
@throws InterruptedException if this thread is interrupted while recording the DDL statements
inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/mysql-cdc/src/main/java/io/debezium/connector/mysql/MySqlStreamingChangeEventSource.java