From 6fe207eb4b85c92c2b11c266de90bd57e23c9922 Mon Sep 17 00:00:00 2001 From: Mingyu Chen Date: Thu, 14 Sep 2023 18:36:09 +0800 Subject: [PATCH] [fix](broker) do not close filesystem(#24357) same as #24128 To avoid Filesystem closed error --- .../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 {