in paimon-python-java-bridge/src/main/java/org/apache/paimon/python/ParallelBytesReader.java [140:154]
private void closeResources() {
for (RecordReaderIterator<InternalRow> iterator : iterators) {
try {
iterator.close();
} catch (Exception e) {
throw new RuntimeException(e);
}
}
iterators.clear();
for (ArrowFormatWriter arrowFormatWriter : arrowFormatWriters) {
arrowFormatWriter.close();
}
arrowFormatWriters.clear();
}