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

do not push execution id for column redefinition task

Browse Source
This commit is contained in:
Charles0429
2022-11-22 03:40:37 +00:00
committed by wangzelin.wzl
parent 44dd39c81d
commit c18134e07f
2 changed files with 1 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
src/rootserver/ddl_task/ob_column_redefinition_task.cpp
View File

@ -66,6 +66,7 @@ int ObColumnRedefinitionTask::init(const uint64_t tenant_id, const int64_t task_
task_version_ = OB_COLUMN_REDEFINITION_TASK_VERSION; task_version_ = OB_COLUMN_REDEFINITION_TASK_VERSION;
task_id_ = task_id; task_id_ = task_id;
parallelism_ = parallelism; parallelism_ = parallelism;
execution_id_ = 1L;
is_inited_ = true; is_inited_ = true;
} }
return ret; return ret;

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

@ -1113,8 +1113,6 @@ int ObDDLScheduler::schedule_column_redefinition_task(const ObDDLTaskRecord &tas
if (OB_ENTRY_EXIST != ret) { if (OB_ENTRY_EXIST != ret) {
LOG_WARN("inner schedule task failed", K(ret), K(*redefinition_task)); LOG_WARN("inner schedule task failed", K(ret), K(*redefinition_task));
} }
} else if (OB_FAIL(redefinition_task->push_execution_id())) {
LOG_WARN("failed to push execution id", K(ret));
} }
if (OB_FAIL(ret) && nullptr != redefinition_task) { if (OB_FAIL(ret) && nullptr != redefinition_task) {
redefinition_task->~ObColumnRedefinitionTask(); redefinition_task->~ObColumnRedefinitionTask();