[fix](recvr) catch exception of transmit_block (#39882)

BP #39881
2024-08-25 00:25:20 +08:00
parent e0534c9bfc
commit 8dbd73988a
1 changed files with 1 additions and 1 deletions
--- 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();