@Override
    public WriteResult complete() throws IOException {
        close();

        Preconditions.checkState(failure == null, "Cannot return results from failed writer", failure);

        return WriteResult.builder()
                .addDataFiles(completedDataFiles)
                .addDeleteFiles(completedDeleteFiles)
                .addReferencedDataFiles(referencedDataFiles)
                .build();
    }
Copied from iceberg 1.1.x. Modify List to concurrent List.
@param <T>
inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/iceberg/src/main/java/org/apache/inlong/sort/iceberg/sink/trick/BaseTaskWriter.java