This is an automated email from the ASF dual-hosted git repository. kxiao pushed a commit to branch branch-2.0 in repository https://gitbox.apache.org/repos/asf/doris.git
commit e77bb747408f76c68cbbc4324d7b946926e2c10a Author: Mingyu Chen <[email protected]> AuthorDate: Thu Sep 14 18:36:09 2023 +0800 [fix](broker) do not close filesystem(#24357) same as #24128 To avoid Filesystem closed error --- .../src/main/java/org/apache/doris/broker/hdfs/BrokerFileSystem.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/fs_brokers/apache_hdfs_broker/src/main/java/org/apache/doris/broker/hdfs/BrokerFileSystem.java b/fs_brokers/apache_hdfs_broker/src/main/java/org/apache/doris/broker/hdfs/BrokerFileSystem.java index 22f6925d31..e3e27fe1c2 100644 --- a/fs_brokers/apache_hdfs_broker/src/main/java/org/apache/doris/broker/hdfs/BrokerFileSystem.java +++ b/fs_brokers/apache_hdfs_broker/src/main/java/org/apache/doris/broker/hdfs/BrokerFileSystem.java @@ -55,7 +55,8 @@ public class BrokerFileSystem { try { if (this.dfsFileSystem != null) { try { - this.dfsFileSystem.close(); + // do not close file system, it will be closed automatically. + // this.dfsFileSystem.close(); } catch (Exception e) { logger.error("errors while close file system", e); } finally { --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
