public void flush() throws IOException {
        long startTime = System.currentTimeMillis();

        session.flush();

        Tuple2<Long, Integer> consumeTime = Tuple2.of(System.currentTimeMillis() - startTime, applyNum);
        consumeTimes.add(consumeTime);
        applyNum = 0;
        printConsumeTimes(false);
    }
The exception caught in asynchronous tasks.
inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/kudu/src/main/java/org/apache/inlong/sort/kudu/sink/KuduWriter.java