private boolean checkFlushException(String tableIdentifier) {
        Exception ex = flushExceptionMap.get(tableIdentifier);
        if (!multipleSink || ex == null || SchemaUpdateExceptionPolicy.LOG_WITH_IGNORE == schemaUpdatePolicy) {
            return false;
        }
        if (SchemaUpdateExceptionPolicy.THROW_WITH_STOP == schemaUpdatePolicy) {
            throw new RuntimeException("Writing records to streamload failed, tableIdentifier=" + tableIdentifier, ex);
        }
        return true;
    }
A builder used to set parameters to the output format's configuration in a fluent way.

@return builder
inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/doris/src/main/java/org/apache/inlong/sort/doris/table/DorisDynamicSchemaOutputFormat.java