hcq/oceanbase
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

Fix not report error when push back ObGranuleTaskInfo failed

Browse Source
This commit is contained in:
sdc
2023-07-27 05:18:26 +00:00
committed by ob-robot
parent fbdc721784
commit 6ec6b418d0
2 changed files with 17 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
src/sql/executor/ob_task_info.cpp
View File

@ -92,5 +92,21 @@ int ObTaskInfo::ObRangeLocation::assign(const ObTaskInfo::ObRangeLocation &range
return ret; return ret;
} }
int ObGranuleTaskInfo::assign(const ObGranuleTaskInfo &other)
{
int ret = OB_SUCCESS;
if (this != &other) {
if (OB_FAIL(ranges_.assign(other.ranges_))) {
LOG_WARN("assign ranges_ failed", K(ret));
} else if (OB_FAIL(ss_ranges_.assign(other.ss_ranges_))) {
LOG_WARN("assign ss_ranges_ failed", K(ret));
} else {
tablet_loc_ = other.tablet_loc_;
task_id_ = other.task_id_;
}
}
return ret;
}
} }
} }

1
src/sql/executor/ob_task_info.h
View File

@ -92,6 +92,7 @@ public:
task_id_(0) task_id_(0)
{ } { }
virtual ~ObGranuleTaskInfo() { } virtual ~ObGranuleTaskInfo() { }
int assign(const ObGranuleTaskInfo &other);
TO_STRING_KV(K_(ranges), K_(ss_ranges), K_(task_id)); TO_STRING_KV(K_(ranges), K_(ss_ranges), K_(task_id));
public: public:
common::ObSEArray<common::ObNewRange, 1> ranges_; common::ObSEArray<common::ObNewRange, 1> ranges_;