private void runWithRetry(ApplyAction action, int maxRetries) {
        for (int retry = 0; retry <= maxRetries; retry++) {
            try {
                action.call();
                break;
            } catch (IOException e) {
                LOG.error("Kudu applyRow error, retryTime:" + retry, e);
                try {
                    Thread.sleep((retry + 1) * 1000L);
                } catch (InterruptedException ignore) {
                }
                if (retry >= maxRetries) {
                    flushThrowable.compareAndSet(null, e);
                }
            }
        }
    }
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