private RespContent load(String tableIdentifier, String result) throws IOException {
        String[] tableWithDb = tableIdentifier.split("\\.");
        RespContent respContent = null;
        for (int i = 0; i <= executionOptions.getMaxRetries(); i++) {
            try {
                respContent = dorisStreamLoad.load(tableWithDb[0], tableWithDb[1], result);
                break;
            } catch (StreamLoadException e) {
                LOG.error("doris sink error, retry times = {}", i, e);
                if (i >= executionOptions.getMaxRetries()) {
                    throw new IOException(e);
                }
                try {
                    dorisStreamLoad.setHostPort(getBackend());
                    LOG.warn("streamload error,switch be: {}",
                            dorisStreamLoad.getLoadUrlStr(tableWithDb[0], tableWithDb[1]), e);
                    Thread.sleep(1000L * i);
                } catch (InterruptedException ex) {
                    Thread.currentThread().interrupt();
                    throw new IOException("unable to flush; interrupted while doing another attempt", e);
                }
            }
        }
        return respContent;
    }
format data to csv or json

@param values
@param format
@return string
@throws JsonProcessingException
inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/doris/src/main/java/org/apache/inlong/sort/doris/table/DorisDynamicSchemaOutputFormat.java