private void initSchedulerTask() {
        try {
            if (batchWaitInterval > 0) {
                this.scheduler = new ScheduledThreadPoolExecutor(
                        1,
                        new DTThreadFactory("kudu-batch-flusher")
                );

                this.scheduledFuture = this.scheduler.scheduleWithFixedDelay(
                        this::flush, batchWaitInterval, batchWaitInterval, TimeUnit.MILLISECONDS);
            }
        } catch (Exception e) {
            LOG.error("init schedule task failed !");
            throw new RuntimeException(e);
        }
    }
init the scheduler task of {@link KuduOutputFormat#flush()}
kudu/kudu-sink/src/main/java/com/dtstack/flink/sql/sink/kudu/KuduOutputFormat.java