public void endInput() {
        final List<WriteStatus> writeStatus = this.writerHelper.getWriteStatuses(this.taskID);

        final WriteMetadataEvent event = WriteMetadataEvent.builder()
                .taskID(taskID)
                .instantTime(this.writerHelper.getInstantTime())
                .writeStatus(writeStatus)
                .lastBatch(true)
                .endInput(true)
                .build();
        this.eventGateway.sendEventToCoordinator(event);
    }
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