diff --git a/src/pl/sys_package/ob_dbms_scheduler_mysql.cpp b/src/pl/sys_package/ob_dbms_scheduler_mysql.cpp index 66d507fce5..098815d22d 100644 --- a/src/pl/sys_package/ob_dbms_scheduler_mysql.cpp +++ b/src/pl/sys_package/ob_dbms_scheduler_mysql.cpp @@ -111,7 +111,7 @@ int ObDBMSSchedulerMysql::disable( OZ (dml.add_column("enabled", false)); OZ (dml.splice_update_sql(OB_ALL_TENANT_SCHEDULER_JOB_TNAME, sql)); OZ (execute_sql(ctx, sql, affected_rows)); - CK (OB_LIKELY(1 == affected_rows)); + CK (OB_LIKELY(1 == affected_rows || 2 == affected_rows)); return ret; } @@ -135,7 +135,7 @@ int ObDBMSSchedulerMysql::enable( OZ (dml.add_column("enabled", true)); OZ (dml.splice_update_sql(OB_ALL_TENANT_SCHEDULER_JOB_TNAME, sql)); OZ (execute_sql(ctx, sql, affected_rows)); - CK (OB_LIKELY(1 == affected_rows)); + CK (OB_LIKELY(1 == affected_rows || 2 == affected_rows)); return ret; } @@ -171,7 +171,7 @@ int ObDBMSSchedulerMysql::set_attribute( } else if (is_stat_window_attr) { OZ (dml.splice_update_sql(OB_ALL_TENANT_SCHEDULER_JOB_TNAME, sql)); OZ (execute_sql(ctx, sql, affected_rows)); - CK (1 == affected_rows); + CK (1 == affected_rows || 2 == affected_rows); } else { OZ (params.at(1).get_varchar(attr_name)); OZ (params.at(2).get_varchar(attr_val));