(auron) branch master updated: [AURON #2116] Make libInputStream auto-close when creating in Flink/Spark AuronAdaptor. (#2117)

[zhangmang]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 2b77f1ec [AURON #2116] Make libInputStream auto-close when creating in 
Flink/Spark AuronAdaptor. (#2117)
2b77f1ec is described below

commit 2b77f1ec6776618891d908403c0edd3ea2091111
Author: Yuepeng Pan <panyuep...@apache.org>
AuthorDate: Thu Mar 26 12:26:23 2026 +0800

    [AURON #2116] Make libInputStream auto-close when creating in Flink/Spark 
AuronAdaptor. (#2117)
    
    # Which issue does this PR close?
    
    Closes #2116
    
    # Rationale for this change
    
    fix the input stream leaking.
    
    # What changes are included in this PR?
    
    Make libInputStream auto-close when creating in FlinkAuronAdaptor.java
    
    # Are there any user-facing changes?
    
    N.A
    
    # How was this patch tested?
    
    N.A
    
    Signed-off-by: Yuepeng Pan <panyuep...@apache.org>
---
 .../src/main/java/org/apache/auron/jni/FlinkAuronAdaptor.java          | 3 +--
 .../src/main/java/org/apache/auron/jni/SparkAuronAdaptor.java          | 3 +--
 2 files changed, 2 insertions(+), 4 deletions(-)

diff --git 
a/auron-flink-extension/auron-flink-runtime/src/main/java/org/apache/auron/jni/FlinkAuronAdaptor.java
 
b/auron-flink-extension/auron-flink-runtime/src/main/java/org/apache/auron/jni/FlinkAuronAdaptor.java
index ba95f93a..d8781356 100644
--- 
a/auron-flink-extension/auron-flink-runtime/src/main/java/org/apache/auron/jni/FlinkAuronAdaptor.java
+++ 
b/auron-flink-extension/auron-flink-runtime/src/main/java/org/apache/auron/jni/FlinkAuronAdaptor.java
@@ -35,8 +35,7 @@ public class FlinkAuronAdaptor extends AuronAdaptor {
     public void loadAuronLib() {
         String libName = System.mapLibraryName("auron");
         ClassLoader classLoader = AuronAdaptor.class.getClassLoader();
-        try {
-            InputStream libInputStream = 
classLoader.getResourceAsStream(libName);
+        try (InputStream libInputStream = 
classLoader.getResourceAsStream(libName)) {
             File tempFile = File.createTempFile("libauron-", ".tmp");
             tempFile.deleteOnExit();
             Files.copy(libInputStream, tempFile.toPath(), 
StandardCopyOption.REPLACE_EXISTING);
diff --git 
a/spark-extension/src/main/java/org/apache/auron/jni/SparkAuronAdaptor.java 
b/spark-extension/src/main/java/org/apache/auron/jni/SparkAuronAdaptor.java
index 3bf45cb5..0d90957b 100644
--- a/spark-extension/src/main/java/org/apache/auron/jni/SparkAuronAdaptor.java
+++ b/spark-extension/src/main/java/org/apache/auron/jni/SparkAuronAdaptor.java
@@ -42,8 +42,7 @@ public class SparkAuronAdaptor extends AuronAdaptor {
     public void loadAuronLib() {
         String libName = System.mapLibraryName("auron");
         ClassLoader classLoader = AuronAdaptor.class.getClassLoader();
-        try {
-            InputStream libInputStream = 
classLoader.getResourceAsStream(libName);
+        try (InputStream libInputStream = 
classLoader.getResourceAsStream(libName)) {
             File tempFile = File.createTempFile("libauron-", ".tmp");
             tempFile.deleteOnExit();
             Files.copy(libInputStream, tempFile.toPath(), 
StandardCopyOption.REPLACE_EXISTING);