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 {