diff --git a/be/src/vec/runtime/vdata_stream_recvr.cpp b/be/src/vec/runtime/vdata_stream_recvr.cpp
index 912ecf5398..0cf5d03a96 100644
--- a/be/src/vec/runtime/vdata_stream_recvr.cpp
+++ b/be/src/vec/runtime/vdata_stream_recvr.cpp
@@ -164,7 +164,7 @@ Status VDataStreamRecvr::SenderQueue::add_block(const PBlock& pblock, int be_num
     {
         SCOPED_RAW_TIMER(&deserialize_time);
         block = Block::create_unique();
-        RETURN_IF_ERROR(block->deserialize(pblock));
+        RETURN_IF_ERROR_OR_CATCH_EXCEPTION(block->deserialize(pblock));
     }
 
     const auto rows = block->rows();