diff --git a/be/src/io/fs/broker_file_system.cpp b/be/src/io/fs/broker_file_system.cpp index 44582a0ff8..6096a0540c 100644 --- a/be/src/io/fs/broker_file_system.cpp +++ b/be/src/io/fs/broker_file_system.cpp @@ -416,7 +416,7 @@ Status BrokerFileSystem::download_impl(const Path& remote_file, const Path& loca RETURN_IF_ERROR(local_writer->append({read_buf.get(), read_len})); } // file_handler should be closed before calculating checksum - return Status::OK(); + return local_writer->close(); } Status BrokerFileSystem::read_file(const TBrokerFD& fd, size_t offset, size_t bytes_req,