public synchronized void close() {
        if (!closed) {
            closed = true;

            LOGGER.info("StarRocks Sink is about to close.");
            this.bufferMap.clear();

            if (scheduledFuture != null) {
                scheduledFuture.cancel(false);
                scheduler.shutdown();
            }
            if (jdbcConnProvider != null) {
                jdbcConnProvider.close();
            }

            offerEOF();
        }
        checkFlushException();
    }
If a table writing throws exception, ignore it when receiving data later again
inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/starrocks/src/main/java/org/apache/inlong/sort/starrocks/manager/StarRocksSinkManager.java