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

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


The following commit(s) were added to refs/heads/master by this push:
     new 449e03f3d80 Improve AdvisorConfigurationLoader close input stream when 
config loaded (#37912)
449e03f3d80 is described below

commit 449e03f3d80e41e057b23a3357eb489f673037cc
Author: jiangML <[email protected]>
AuthorDate: Fri Jan 30 23:30:02 2026 +0800

    Improve AdvisorConfigurationLoader close input stream when config loaded 
(#37912)
---
 .../agent/core/advisor/config/AdvisorConfigurationLoader.java      | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git 
a/agent/core/src/main/java/org/apache/shardingsphere/agent/core/advisor/config/AdvisorConfigurationLoader.java
 
b/agent/core/src/main/java/org/apache/shardingsphere/agent/core/advisor/config/AdvisorConfigurationLoader.java
index 6085c36d9d6..ad5ccf9e6bc 100644
--- 
a/agent/core/src/main/java/org/apache/shardingsphere/agent/core/advisor/config/AdvisorConfigurationLoader.java
+++ 
b/agent/core/src/main/java/org/apache/shardingsphere/agent/core/advisor/config/AdvisorConfigurationLoader.java
@@ -23,6 +23,7 @@ import 
org.apache.shardingsphere.agent.core.advisor.config.yaml.loader.YamlAdvis
 import 
org.apache.shardingsphere.agent.core.advisor.config.yaml.swapper.YamlAdvisorsConfigurationSwapper;
 import 
org.apache.shardingsphere.agent.core.plugin.classloader.AgentPluginClassLoader;
 
+import java.io.IOException;
 import java.io.InputStream;
 import java.util.Collection;
 import java.util.HashMap;
@@ -57,6 +58,12 @@ public final class AdvisorConfigurationLoader {
             }
             Optional.ofNullable(advisorsResourceStream)
                     .ifPresent(optional -> mergeConfigurations(result, 
YamlAdvisorsConfigurationSwapper.swap(YamlAdvisorsConfigurationLoader.load(optional),
 each)));
+            if (null != advisorsResourceStream) {
+                try {
+                    advisorsResourceStream.close();
+                } catch (final IOException ignored) {
+                }
+            }
         }
         return result;
     }

Reply via email to