From 8dbd73988ae15ea24875bc91c68b2671d67a0c02 Mon Sep 17 00:00:00 2001
From: TengJianPing <18241664+jacktengg@users.noreply.github.com>
Date: Sun, 25 Aug 2024 00:25:20 +0800
Subject: [PATCH] [fix](recvr) catch exception of transmit_block (#39882)

BP #39881
---
 be/src/vec/runtime/vdata_stream_recvr.cpp | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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();