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

update the job id offset of mview scheduler job

Browse Source
This commit is contained in:
leftgeek
2024-01-18 10:42:26 +00:00
committed by ob-robot
parent d97553e3e5
commit b28e945f14
4 changed files with 3 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/pl/sys_package/ob_dbms_scheduler_mysql.cpp
View File

@ -223,7 +223,7 @@ int ObDBMSSchedulerMysql::_generate_job_id(int64_t tenant_id, int64_t &max_job_i
if (OB_FAIL(storage::ObCommonIDUtils::gen_unique_id(tenant_id, raw_id))) { if (OB_FAIL(storage::ObCommonIDUtils::gen_unique_id(tenant_id, raw_id))) {
LOG_WARN("gen unique id failed", K(ret), K(tenant_id)); LOG_WARN("gen unique id failed", K(ret), K(tenant_id));
} else { } else {
max_job_id = raw_id.id() + JOB_ID_OFFSET; max_job_id = raw_id.id() + ObDBMSSchedTableOperator::JOB_ID_OFFSET;
} }
return ret; return ret;
} }

1
src/pl/sys_package/ob_dbms_scheduler_mysql.h
View File

@ -27,7 +27,6 @@ public:
virtual ~ObDBMSSchedulerMysql() {} virtual ~ObDBMSSchedulerMysql() {}
public: public:
static constexpr int64_t JOB_ID_OFFSET = 1000000L;
#define DECLARE_FUNC(func) \ #define DECLARE_FUNC(func) \
static int func(sql::ObExecContext &ctx, sql::ParamStore &params, common::ObObj &result); static int func(sql::ObExecContext &ctx, sql::ParamStore &params, common::ObObj &result);

3
src/storage/mview/ob_mview_sched_job_utils.cpp
View File

@ -14,6 +14,7 @@
#include "storage/mview/ob_mview_sched_job_utils.h" #include "storage/mview/ob_mview_sched_job_utils.h"
#include "observer/dbms_scheduler/ob_dbms_sched_job_utils.h" #include "observer/dbms_scheduler/ob_dbms_sched_job_utils.h"
#include "observer/dbms_scheduler/ob_dbms_sched_table_operator.h"
#include "storage/ob_common_id_utils.h" #include "storage/ob_common_id_utils.h"
#include "lib/ob_errno.h" #include "lib/ob_errno.h"
#include "lib/oblog/ob_log_module.h" #include "lib/oblog/ob_log_module.h"
@ -53,7 +54,7 @@ int ObMViewSchedJobUtils::generate_job_id(
if (OB_FAIL(ObCommonIDUtils::gen_unique_id_by_rpc(tenant_id, raw_id))) { if (OB_FAIL(ObCommonIDUtils::gen_unique_id_by_rpc(tenant_id, raw_id))) {
LOG_WARN("failed to gen unique id by rpc", KR(ret), K(tenant_id)); LOG_WARN("failed to gen unique id by rpc", KR(ret), K(tenant_id));
} else { } else {
job_id = raw_id.id() + ObMViewSchedJobUtils::JOB_ID_OFFSET; job_id = raw_id.id() + ObDBMSSchedTableOperator::JOB_ID_OFFSET;
} }
} }
return ret; return ret;

3
src/storage/mview/ob_mview_sched_job_utils.h
View File

@ -101,9 +101,6 @@ public:
const ParseNode &node, const ParseNode &node,
common::ObIAllocator &allocator, common::ObIAllocator &allocator,
int64_t &timestamp); int64_t &timestamp);
public:
static constexpr int64_t JOB_ID_OFFSET = 1000000L;
}; };
} // namespace storage } // namespace storage
} // namespace oceanbase } // namespace oceanbase