private void cacheWriteResultAndRecreateWriter() throws IOException {
        LOGGER.info("close all open file and cache writeResult");
        cachedWriteResults.add(writer.complete());
        this.writer = taskWriterFactory.create();
    }
this method should only be called in open() method
inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/iceberg/src/main/java/org/apache/inlong/sort/iceberg/sink/multiple/IcebergSingleStreamWriter.java