diff --git a/src/pl/sys_package/ob_dbms_scheduler_mysql.cpp b/src/pl/sys_package/ob_dbms_scheduler_mysql.cpp index 098815d22d..dce08d7efd 100644 --- a/src/pl/sys_package/ob_dbms_scheduler_mysql.cpp +++ b/src/pl/sys_package/ob_dbms_scheduler_mysql.cpp @@ -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))) { LOG_WARN("gen unique id failed", K(ret), K(tenant_id)); } else { - max_job_id = raw_id.id() + JOB_ID_OFFSET; + max_job_id = raw_id.id() + ObDBMSSchedTableOperator::JOB_ID_OFFSET; } return ret; } diff --git a/src/pl/sys_package/ob_dbms_scheduler_mysql.h b/src/pl/sys_package/ob_dbms_scheduler_mysql.h index 8fc1646122..4ec9e418e1 100644 --- a/src/pl/sys_package/ob_dbms_scheduler_mysql.h +++ b/src/pl/sys_package/ob_dbms_scheduler_mysql.h @@ -27,7 +27,6 @@ public: virtual ~ObDBMSSchedulerMysql() {} public: - static constexpr int64_t JOB_ID_OFFSET = 1000000L; #define DECLARE_FUNC(func) \ static int func(sql::ObExecContext &ctx, sql::ParamStore ¶ms, common::ObObj &result); diff --git a/src/storage/mview/ob_mview_sched_job_utils.cpp b/src/storage/mview/ob_mview_sched_job_utils.cpp index 72cf376b36..031eae340a 100644 --- a/src/storage/mview/ob_mview_sched_job_utils.cpp +++ b/src/storage/mview/ob_mview_sched_job_utils.cpp @@ -14,6 +14,7 @@ #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_table_operator.h" #include "storage/ob_common_id_utils.h" #include "lib/ob_errno.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))) { LOG_WARN("failed to gen unique id by rpc", KR(ret), K(tenant_id)); } else { - job_id = raw_id.id() + ObMViewSchedJobUtils::JOB_ID_OFFSET; + job_id = raw_id.id() + ObDBMSSchedTableOperator::JOB_ID_OFFSET; } } return ret; diff --git a/src/storage/mview/ob_mview_sched_job_utils.h b/src/storage/mview/ob_mview_sched_job_utils.h index 0d3e17858c..ddf6a201b4 100644 --- a/src/storage/mview/ob_mview_sched_job_utils.h +++ b/src/storage/mview/ob_mview_sched_job_utils.h @@ -101,9 +101,6 @@ public: const ParseNode &node, common::ObIAllocator &allocator, int64_t ×tamp); - -public: - static constexpr int64_t JOB_ID_OFFSET = 1000000L; }; } // namespace storage } // namespace oceanbase