(paimon) branch master updated: [core] Remove deleteOnExit method to avoid out of memory (#4151)

[lzljs3620320]

This is an automated email from the ASF dual-hosted git repository.

lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git


The following commit(s) were added to refs/heads/master by this push:
     new c94c774d6 [core] Remove deleteOnExit method to avoid out of memory 
(#4151)
c94c774d6 is described below

commit c94c774d638c902c5b124725882cb7517a66ea01
Author: YeJunHao <41894543+leaves12...@users.noreply.github.com>
AuthorDate: Tue Sep 10 11:14:20 2024 +0800

    [core] Remove deleteOnExit method to avoid out of memory (#4151)
---
 .../main/java/org/apache/paimon/lookup/hash/HashLookupStoreWriter.java | 3 ---
 1 file changed, 3 deletions(-)

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 f34aad5b3..3307377a2 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 class HashLookupStoreWriter implements 
LookupStoreWriter {
             // 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 @@ public class HashLookupStoreWriter implements 
LookupStoreWriter {
         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 @@ public class HashLookupStoreWriter implements 
LookupStoreWriter {
         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)));