private void initWriterHelper() {
        String instant = instantToWrite();
        this.writerHelper = WriterHelpers.getWriterHelper(this.config, this.writeClient.getHoodieTable(),
                this.writeClient.getConfig(),
                instant, this.taskID, getRuntimeContext().getNumberOfParallelSubtasks(),
                getRuntimeContext().getAttemptNumber(),
                this.rowType);
    }
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