diff --git a/be/src/io/fs/hdfs_file_system.cpp b/be/src/io/fs/hdfs_file_system.cpp index 22b4784ea6..e41671e493 100644 --- a/be/src/io/fs/hdfs_file_system.cpp +++ b/be/src/io/fs/hdfs_file_system.cpp @@ -381,8 +381,7 @@ Status HdfsFileSystem::download_impl(const Path& remote_file, const Path& local_ RETURN_IF_ERROR(local_writer->append({read_buf.get(), read_len})); } - - return Status::OK(); + return local_writer->close(); } HdfsFileSystemHandle* HdfsFileSystem::get_handle() {