@Override
    public void abort() throws IOException {
        close();

        // clean up files created by this writer
        Tasks.foreach(Iterables.concat(completedDataFiles, completedDeleteFiles))
                .executeWith(ThreadPools.getWorkerPool())
                .throwFailureWhenFinished()
                .noRetry()
                .run(file -> io.deleteFile(file.path().toString()));
    }
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