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;
}