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

[standby]fix type transform can not accumulate in primary cluster

Browse Source
This commit is contained in:
maosy 2021-09-02 13:10:02 +08:00 committed by wangzelin.wzl
parent 29d1fd04e0
commit 5f209b30fe
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/rootserver/ob_locality_checker.cpp
View File

@ -130,7 +130,8 @@ int ObLocalityChecker::try_accumulate_task_info(common::ObIArray<ObTypeTransform
} else if (cur_replica.server_->server_ == this_task_info->get_dest().get_server() &&
cur_replica.replica_type_ == this_task_info->get_src_member().get_replica_type() &&
dst_type == this_task_info->get_dest().get_replica_type() && cur_leader == this_leader &&
(is_standby && this_task_info->can_accumulate_in_standby(task_info))) {
(!is_standby // primary cluster or can accumulate in standby
|| (is_standby && this_task_info->can_accumulate_in_standby(task_info)))) {
if (cur_partition->is_primary() && this_task.get_sub_task_count() >= MAX_BATCH_TYPE_TRANSFORM_COUNT) {
if (OB_FAIL(task_mgr_->add_task(this_task, task_cnt))) {
LOG_WARN("fail to add task", K(ret));