diff --git a/be/src/io/hdfs_file_reader.h b/be/src/io/hdfs_file_reader.h index 95c09d8e015798..15093ba347e71a 100644 --- a/be/src/io/hdfs_file_reader.h +++ b/be/src/io/hdfs_file_reader.h @@ -53,8 +53,8 @@ class HdfsFsHandle { ~HdfsFsHandle() { DCHECK(_ref_cnt == 0); if (hdfs_fs != nullptr) { - // Even if there is an error, the resources associated with the hdfsFS will be freed. - hdfsDisconnect(hdfs_fs); + // DO NOT call hdfsDisconnect(), or we will meet "Filesystem closed" + // hdfsDisconnect(hdfs_fs); } hdfs_fs = nullptr; }