diff --git a/be/src/io/broker_reader.cpp b/be/src/io/broker_reader.cpp
index 1073fd3ac6..34e25930ea 100644
--- a/be/src/io/broker_reader.cpp
+++ b/be/src/io/broker_reader.cpp
@@ -77,8 +77,7 @@ Status BrokerReader::open() {
     request.__set_clientId(client_id(_env, broker_addr));
     request.__set_properties(_properties);
 
-    TBrokerOpenReaderResponse* response = new TBrokerOpenReaderResponse();
-    Defer del_reponse {[&] { delete response; }};
+    std::unique_ptr<TBrokerOpenReaderResponse> response(new TBrokerOpenReaderResponse());
     try {
         Status status;
         BrokerServiceConnection client(client_cache(_env), broker_addr,
diff --git a/be/src/io/fs/broker_file_system.cpp b/be/src/io/fs/broker_file_system.cpp
index 875eb0829b..681fa014d4 100644
--- a/be/src/io/fs/broker_file_system.cpp
+++ b/be/src/io/fs/broker_file_system.cpp
@@ -94,8 +94,7 @@ Status BrokerFileSystem::open_file(const Path& path, FileReaderSPtr* reader,
     request.__set_clientId(client_id(_broker_addr));
     request.__set_properties(_broker_prop);
 
-    TBrokerOpenReaderResponse* response = new TBrokerOpenReaderResponse();
-    Defer del_reponse {[&] { delete response; }};
+    std::unique_ptr<TBrokerOpenReaderResponse> response(new TBrokerOpenReaderResponse());
     try {
         Status status;
         try {