fix some typo error
This commit is contained in:
@ -273,7 +273,7 @@ int ObFlushCacheExecutor::execute(ObExecContext &ctx, ObFlushCacheStmt &stmt)
|
||||
int64_t t_id = stmt.flush_cache_arg_.tenant_ids_.at(i);
|
||||
MTL_SWITCH(t_id) {
|
||||
ObPlanCache* plan_cache = MTL(ObPlanCache*);
|
||||
// not specified db_name, evcit all dbs
|
||||
// not specified db_name, evict all dbs
|
||||
if (db_num == 0) {
|
||||
ret = plan_cache->flush_plan_cache_by_sql_id(OB_INVALID_ID, sql_id);
|
||||
} else { // evict db by db
|
||||
@ -921,7 +921,7 @@ int ObAdminZoneExecutor::construct_servers_in_zone_(
|
||||
} else if (OB_FAIL(st_operator.init(&sql_proxy))) {
|
||||
LOG_WARN("fail to init ObServerTableOperator", KR(ret));
|
||||
} else if (OB_FAIL(st_operator.get(server_statuses))) {
|
||||
LOG_WARN("build server statused from __all_server failed", KR(ret));
|
||||
LOG_WARN("build server statuses from __all_server failed", KR(ret));
|
||||
} else {
|
||||
for (int64_t idx = 0; OB_SUCC(ret) && idx < server_statuses.count(); ++idx) {
|
||||
if (arg.zone_ == server_statuses.at(idx).zone_) {
|
||||
@ -1825,7 +1825,7 @@ int ObClearBalanceTaskExecutor::execute(ObExecContext &ctx, ObClearBalanceTaskSt
|
||||
}
|
||||
|
||||
/*
|
||||
* change tenant should statisfy the following factors:
|
||||
* change tenant should satisfy the following factors:
|
||||
* 0. can't change tenant by proxy.
|
||||
* 1. login tenant is sys.
|
||||
* 2. session is not in trans.
|
||||
@ -2107,7 +2107,7 @@ int ObBackupDatabaseExecutor::execute(ObExecContext &ctx, ObBackupDatabaseStmt &
|
||||
ObString passwd;
|
||||
ObObj value;
|
||||
obrpc::ObBackupDatabaseArg arg;
|
||||
//rs会尝试更新冻结点的schema_version的intervale 5s
|
||||
//rs会尝试更新冻结点的schema_version的interval 5s
|
||||
const int64_t SECOND = 1* 1000 * 1000; //1s
|
||||
const int64_t MAX_RETRY_NUM = UPDATE_SCHEMA_ADDITIONAL_INTERVAL / SECOND + 1;
|
||||
if (OB_ISNULL(task_exec_ctx)) {
|
||||
@ -2471,7 +2471,7 @@ int ObSetRegionBandwidthExecutor::execute(ObExecContext &ctx, ObSetRegionBandwid
|
||||
} else if (OB_FAIL(sql_proxy->write(session_info->get_effective_tenant_id()/*get_priv_tenant_id ???*/,
|
||||
sql_str.ptr(),
|
||||
affected_rows))) {
|
||||
LOG_WARN("failed to excutet sql write", K(ret), K(sql_str));
|
||||
LOG_WARN("failed to execute sql write", K(ret), K(sql_str));
|
||||
} else {
|
||||
LOG_INFO("ObSetRegionBandwidthExecutor::execute", K(stmt), K(ctx), K(sql_str));
|
||||
}
|
||||
|
||||
@ -140,8 +140,8 @@ int ObCreateIndexExecutor::set_drop_index_stmt_str(
|
||||
return ret;
|
||||
}
|
||||
|
||||
// is_update_global_indexes = true: drop/truncate partition will trigger index buiding, no need delete failed index at exception
|
||||
// is_update_global_indexes = false: create index/alter table add index will trigger index buiding, need delete failed index at exception
|
||||
// is_update_global_indexes = true: drop/truncate partition will trigger index building, no need delete failed index at exception
|
||||
// is_update_global_indexes = false: create index/alter table add index will trigger index building, need delete failed index at exception
|
||||
int ObCreateIndexExecutor::sync_check_index_status(sql::ObSQLSessionInfo &my_session,
|
||||
obrpc::ObCommonRpcProxy &common_rpc_proxy,
|
||||
const obrpc::ObCreateIndexArg &create_index_arg,
|
||||
@ -321,7 +321,7 @@ int ObDropIndexExecutor::wait_drop_index_finish(
|
||||
}
|
||||
if (OB_FAIL(ret)) {
|
||||
} else if (OB_FAIL(session.check_session_status())) {
|
||||
LOG_WARN("session exeception happened", K(ret));
|
||||
LOG_WARN("session exception happened", K(ret));
|
||||
} else {
|
||||
ob_usleep(retry_interval);
|
||||
}
|
||||
|
||||
@ -241,7 +241,7 @@ private:
|
||||
|
||||
/*
|
||||
* ObKMPStateMachine is a str matcher
|
||||
* efficently implimented using KMP algorithem
|
||||
* efficiently implemented using KMP algorithm
|
||||
* to detect a given str from a char stream
|
||||
*/
|
||||
class ObKMPStateMachine
|
||||
|
||||
Reference in New Issue
Block a user