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

fix: job maybe not execute and maybe purge log

Browse Source
This commit is contained in:
obdev
2023-09-09 12:20:48 +00:00
committed by ob-robot
parent ad99419dc9
commit bbad1b2bb3
2 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/observer/dbms_scheduler/ob_dbms_sched_job_master.cpp
View File

@ -672,6 +672,7 @@ int ObDBMSSchedJobMaster::register_jobs(uint64_t tenant_id,
} else if (OB_HASH_NOT_EXIST) {
OZ (register_job(job_info));
OZ (alive_jobs_.set_refactored(job_info.get_job_id_with_tenant()));
LOG_INFO("register new dbms sched job", K(ret), K(tenant_id), K(job_info), KPC(job_key));
} else {
LOG_ERROR("dbms sched job master check job exist failed", K(ret), K(job_info));
}
@ -756,7 +757,7 @@ int ObDBMSSchedJobMaster::register_job(
if (OB_FAIL(ret) && OB_NOT_NULL(job_key)) {
allocator_.free(job_key);
}
LOG_INFO("register new dbms sched job", K(ret), K(job_info), KPC(job_key), K(ignore_nextdate));
LOG_INFO("register dbms sched job", K(ret), K(job_info), KPC(job_key), K(ignore_nextdate));
return ret;
}

5
src/observer/dbms_scheduler/ob_dbms_sched_job_master.h
View File

@ -53,7 +53,7 @@ public:
ObDBMSSchedJobKey(
uint64_t tenant_id, bool is_oracle_tenant, uint64_t job_id,
uint64_t execute_at, uint64_t delay,
bool check_job, bool check_new, bool check_new_tenant)
bool check_job, bool check_new, bool check_new_tenant, bool purge_run_detail = false)
: tenant_id_(tenant_id),
is_oracle_tenant_(is_oracle_tenant),
job_id_(job_id),
@ -61,7 +61,8 @@ public:
delay_(delay),
check_job_(check_job),
check_new_(check_new),
check_new_tenant_(check_new_tenant) {}
check_new_tenant_(check_new_tenant),
purge_run_detail_(purge_run_detail) {}
virtual ~ObDBMSSchedJobKey() {}