diff --git a/paimon-common/src/main/java/org/apache/paimon/lookup/hash/HashLookupStoreWriter.java b/paimon-common/src/main/java/org/apache/paimon/lookup/hash/HashLookupStoreWriter.java index f34aad5b3b8a..3307377a2706 100644 --- a/paimon-common/src/main/java/org/apache/paimon/lookup/hash/HashLookupStoreWriter.java +++ b/paimon-common/src/main/java/org/apache/paimon/lookup/hash/HashLookupStoreWriter.java @@ -247,7 +247,6 @@ public Context close() throws IOException { // Write bloom filter file if (bloomFilter != null) { File bloomFilterFile = new File(tempFolder, "bloomfilter.dat"); - bloomFilterFile.deleteOnExit(); try (FileOutputStream bfOutputStream = new FileOutputStream(bloomFilterFile)) { bfOutputStream.write(bloomFilter.getBuffer().getArray()); LOG.info("Bloom filter size: {} bytes", bloomFilter.getBuffer().size()); @@ -459,7 +458,6 @@ private DataOutputStream getDataStream(int keyLength) throws IOException { DataOutputStream dos = dataStreams[keyLength]; if (dos == null) { File file = new File(tempFolder, "data" + keyLength + ".dat"); - file.deleteOnExit(); dataFiles[keyLength] = file; dos = new DataOutputStream(new BufferedOutputStream(new FileOutputStream(file))); @@ -488,7 +486,6 @@ private DataOutputStream getIndexStream(int keyLength) throws IOException { DataOutputStream dos = indexStreams[keyLength]; if (dos == null) { File file = new File(tempFolder, "temp_index" + keyLength + ".dat"); - file.deleteOnExit(); indexFiles[keyLength] = file; dos = new DataOutputStream(new BufferedOutputStream(new FileOutputStream(file)));