[fix](broker) do not close filesystem(#24357)

same as #24128
To avoid Filesystem closed error
This commit is contained in:
Mingyu Chen
2023-09-14 18:36:09 +08:00
committed by GitHub
parent eb65cc6954
commit 6fe207eb4b

View File

@ -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 {