From 664a876fd884b93145b6bc2807d7cd50db1ff6d9 Mon Sep 17 00:00:00 2001 From: sdc Date: Tue, 1 Aug 2023 19:48:24 +0000 Subject: [PATCH] [CP] Fix correctness problem in errsim Co-authored-by: qianchanger --- src/sql/executor/ob_task_info.cpp | 15 +++++++++++++++ src/sql/executor/ob_task_info.h | 1 + 2 files changed, 16 insertions(+) diff --git a/src/sql/executor/ob_task_info.cpp b/src/sql/executor/ob_task_info.cpp index 3ae1afce18..2a1a0a3dec 100644 --- a/src/sql/executor/ob_task_info.cpp +++ b/src/sql/executor/ob_task_info.cpp @@ -108,5 +108,20 @@ int ObGranuleTaskInfo::assign(const ObGranuleTaskInfo &other) return ret; } +int ObTaskInfo::ObPartLoc::assign(ObTaskInfo::ObPartLoc &other) +{ + int ret = OB_SUCCESS; + if (OB_FAIL(scan_ranges_.assign(other.scan_ranges_))) { + LOG_WARN("fail to assign scan range", K(ret), K(other.scan_ranges_.count())); + } else { + part_key_ref_id_ = other.part_key_ref_id_; + value_ref_id_ = other.value_ref_id_; + renew_time_ = other.renew_time_; + row_store_ = other.row_store_; + datum_store_ = other.datum_store_; + } + return ret; } + } +} \ No newline at end of file diff --git a/src/sql/executor/ob_task_info.h b/src/sql/executor/ob_task_info.h index cabb97ca2d..2808a24cb1 100644 --- a/src/sql/executor/ob_task_info.h +++ b/src/sql/executor/ob_task_info.h @@ -153,6 +153,7 @@ public: { return common::OB_INVALID_TIMESTAMP != renew_time_; } + int assign(ObPartLoc &other); TO_STRING_KV(K_(scan_ranges), K_(part_key_ref_id), K_(value_ref_id),