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

turn off job class related

Browse Source
This commit is contained in:
obdev 2023-09-08 12:58:39 +08:00 committed by ob-robot
parent 856ae12473
commit 5b22d0a0af
3 changed files with 8 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -615,7 +615,7 @@ int ObDBMSSchedJobMaster::load_and_register_all_jobs(ObDBMSSchedJobKey *job_key)
uint64_t data_version = 0;
if (OB_FAIL(GET_MIN_DATA_VERSION(tenant_ids.at(i), data_version))) {
LOG_WARN("fail to get tenant data version", KR(ret), K(data_version));
} else if (DATA_VERSION_4_2_1_0 <= data_version) {
} else if (MOCK_DATA_VERSION <= data_version) {
//add default job class
OZ (table_operator_.register_default_job_class(tenant_ids.at(i)));
//add purge run detail job

3
src/observer/dbms_scheduler/ob_dbms_sched_job_utils.h
View File

@ -19,6 +19,9 @@
#include "lib/mysqlclient/ob_isql_client.h"
#include "lib/container/ob_iarray.h"
#define MOCK_DATA_VERSION (oceanbase::common::cal_version(9, 9, 9, 9))
namespace oceanbase
{
namespace common

8
src/observer/dbms_scheduler/ob_dbms_sched_table_operator.cpp
View File

@ -128,14 +128,14 @@ int ObDBMSSchedTableOperator::update_for_end(
if (OB_SUCC(ret)) {
if (OB_FAIL(GET_MIN_DATA_VERSION(tenant_id, data_version))) {
LOG_WARN("fail to get tenant data version", KR(ret), K(data_version));
} else if (DATA_VERSION_4_2_1_0 <= data_version) {
} else if (MOCK_DATA_VERSION <= data_version) {
CK (OB_LIKELY(!job_info.job_class_.empty()));
}
}
ObDBMSSchedJobClassInfo job_class_info;
ObArenaAllocator allocator;
if (DATA_VERSION_4_2_1_0 <= data_version) {
if (MOCK_DATA_VERSION <= data_version) {
OZ (get_dbms_sched_job_class_info(tenant_id, job_info.is_oracle_tenant(), job_info.get_job_class(), allocator, job_class_info));
}
// when if failures > 16 then set broken flag.
@ -177,7 +177,7 @@ int ObDBMSSchedTableOperator::update_for_end(
//If a non-existent JOB CLASS is entered when creating a JOB,
//job_run_detail still needs to be recorded.
bool need_write_job_run_detail = true;
if (DATA_VERSION_4_2_1_0 <= data_version) {
if (MOCK_DATA_VERSION <= data_version) {
ObString logging_level = job_class_info.get_logging_level();
if (logging_level.empty()) {
LOG_WARN("logging_level may not assigned");
@ -199,7 +199,7 @@ int ObDBMSSchedTableOperator::update_for_end(
OZ (dml2.add_column("code", err));
OZ (dml2.add_column(
"message", ObHexEscapeSqlStr(errmsg.empty() ? ObString("SUCCESS") : errmsg)));
if (DATA_VERSION_4_2_1_0 <= data_version) {
if (MOCK_DATA_VERSION <= data_version) {
OZ (dml2.add_column("job_class", job_info.job_class_));
}
OZ (dml2.splice_insert_sql(OB_ALL_TENANT_SCHEDULER_JOB_RUN_DETAIL_TNAME, sql2));