From 5d9bb1beec762c150db70a7fd051b6474e44cc47 Mon Sep 17 00:00:00 2001
From: qingsuijiu <642782632@qq.com>
Date: Thu, 29 Feb 2024 09:19:37 +0000
Subject: [PATCH] Resolved the issue of ObDTLIntermResultManager swallowing
 error codes during append_block.

---
 src/sql/dtl/ob_dtl_interm_result_manager.cpp | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/src/sql/dtl/ob_dtl_interm_result_manager.cpp b/src/sql/dtl/ob_dtl_interm_result_manager.cpp
index e28e1c5b13..a7806d1199 100644
--- a/src/sql/dtl/ob_dtl_interm_result_manager.cpp
+++ b/src/sql/dtl/ob_dtl_interm_result_manager.cpp
@@ -104,9 +104,9 @@ void ObAtomicAppendBlockCall::operator() (common::hash::HashMapPair<ObDTLIntermR
       ret_ = OB_INVALID_ARGUMENT;
     } else {
       if (entry.second->use_rich_format_) {
-        entry.second->col_store_->append_block(block_buf_, size_);
+        ret_ = entry.second->col_store_->append_block(block_buf_, size_);
       } else {
-        entry.second->datum_store_->append_block(block_buf_, size_, true);
+        ret_ = entry.second->datum_store_->append_block(block_buf_, size_, true);
       }
       if (is_eof_) {
         entry.second->is_eof_ = is_eof_;
@@ -125,9 +125,9 @@ void ObAtomicAppendPartBlockCall::operator() (common::hash::HashMapPair<ObDTLInt
       ret_ = OB_INVALID_ARGUMENT;
     } else {
       if (entry.second->use_rich_format_) {
-        entry.second->col_store_->append_block_payload(block_buf_ + start_pos_, length_, rows_);
+        ret_ = entry.second->col_store_->append_block_payload(block_buf_ + start_pos_, length_, rows_);
       } else {
-        entry.second->datum_store_->append_block_payload(block_buf_ + start_pos_, length_, rows_, true);
+        ret_ = entry.second->datum_store_->append_block_payload(block_buf_ + start_pos_, length_, rows_, true);
       }
       if (is_eof_) {
         entry.second->is_eof_ = is_eof_;