private void sendBootstrapEvent() {
        WriteMetadataEvent event = WriteMetadataEvent.builder()
                .taskID(taskID)
                .writeStatus(Collections.emptyList())
                .instantTime("")
                .bootstrap(true)
                .build();
        this.eventGateway.sendEventToCoordinator(event);
        LOG.info("Send bootstrap write metadata event to coordinator, task[{}].", taskID);
    }
End input action for batch source.
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/hudi/src/main/java/org/apache/inlong/sort/hudi/sink/bulk/BulkInsertWriteFunction.java