public void close() {
        LOG.info("Closing... KuduConsumerTask");
        flush();
        running = false;
        try {
            kuduWriter.close();
        } catch (KuduException e) {
            LOG.error("Error when close kuduWrite", e);
        }
    }
The maximum number of retries when an exception is caught.
inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/kudu/src/main/java/org/apache/inlong/sort/kudu/source/KuduConsumerTask.java