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

Fix unexpected zero delay schedule time

Browse Source
This commit is contained in:
Hongqin-Li
2023-01-05 04:45:43 +00:00
committed by ob-robot
parent 9726d0fd36
commit a046ae912c
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/rootserver/ddl_task/ob_ddl_scheduler.cpp
View File

@ -312,6 +312,7 @@ void ObDDLScheduler::run1()
ret = OB_NOT_INIT; ret = OB_NOT_INIT;
LOG_WARN("not init", K(ret)); LOG_WARN("not init", K(ret));
} else { } else {
const int64_t thread_cnt = TG_GET_THREAD_CNT(lib::TGDefIDs::DDLTaskExecutor3);
int ret = OB_SUCCESS; int ret = OB_SUCCESS;
ObDDLTask *task = nullptr; ObDDLTask *task = nullptr;
ObDDLTask *first_retry_task = nullptr; ObDDLTask *first_retry_task = nullptr;
@ -339,7 +340,7 @@ void ObDDLScheduler::run1()
} else { } else {
ObCurTraceId::set(task->get_trace_id()); ObCurTraceId::set(task->get_trace_id());
int task_ret = task->process(); int task_ret = task->process();
task->calc_next_schedule_ts(task_ret, task_queue_.get_task_cnt()); task->calc_next_schedule_ts(task_ret, task_queue_.get_task_cnt() + thread_cnt);
if (task->need_retry() && !has_set_stop()) { if (task->need_retry() && !has_set_stop()) {
if (OB_FAIL(task_queue_.add_task_to_last(task))) { if (OB_FAIL(task_queue_.add_task_to_last(task))) {
STORAGE_LOG(ERROR, "fail to add task to last, which should not happen", K(ret), K(*task)); STORAGE_LOG(ERROR, "fail to add task to last, which should not happen", K(ret), K(*task));