fix some typo error
This commit is contained in:
@ -184,7 +184,7 @@ private:
|
|||||||
int wait_leader_switch_out_(
|
int wait_leader_switch_out_(
|
||||||
ObISQLClient &sql_proxy,
|
ObISQLClient &sql_proxy,
|
||||||
const obrpc::ObServerList &svr_list);
|
const obrpc::ObServerList &svr_list);
|
||||||
// construct sql to check waitint-result
|
// construct sql to check waiting-result
|
||||||
// @params[in] svr_list, which servers to stop
|
// @params[in] svr_list, which servers to stop
|
||||||
// @params[in] sql, the sql builded
|
// @params[in] sql, the sql builded
|
||||||
int construct_wait_leader_switch_sql_(
|
int construct_wait_leader_switch_sql_(
|
||||||
@ -206,7 +206,7 @@ private:
|
|||||||
int wait_leader_switch_out_(
|
int wait_leader_switch_out_(
|
||||||
ObISQLClient &sql_proxy,
|
ObISQLClient &sql_proxy,
|
||||||
const obrpc::ObAdminZoneArg &arg);
|
const obrpc::ObAdminZoneArg &arg);
|
||||||
// construct sql to check waitint-result
|
// construct sql to check waiting-result
|
||||||
// @params[in] arg, which zone to stop
|
// @params[in] arg, which zone to stop
|
||||||
// @params[out] sql, the sql builded
|
// @params[out] sql, the sql builded
|
||||||
int construct_wait_leader_switch_sql_(
|
int construct_wait_leader_switch_sql_(
|
||||||
|
|||||||
@ -109,7 +109,7 @@ int ObKillExecutor::get_remote_session_location(const ObKillSessionArg &arg, ObE
|
|||||||
//execute sql
|
//execute sql
|
||||||
if (OB_ISNULL(sql_proxy) || OB_ISNULL(cur_sess)) {
|
if (OB_ISNULL(sql_proxy) || OB_ISNULL(cur_sess)) {
|
||||||
ret = OB_ERR_UNEXPECTED;
|
ret = OB_ERR_UNEXPECTED;
|
||||||
LOG_WARN("sql proxy or sesion from exec context is NULL", K(ret), K(sql_proxy), K(cur_sess));
|
LOG_WARN("sql proxy or session from exec context is NULL", K(ret), K(sql_proxy), K(cur_sess));
|
||||||
} else if (OB_FAIL(generate_read_sql(arg.sess_id_, read_sql))) {
|
} else if (OB_FAIL(generate_read_sql(arg.sess_id_, read_sql))) {
|
||||||
LOG_WARN("fail to generate sql", K(ret), K(read_sql), K(*cur_sess), K(arg));
|
LOG_WARN("fail to generate sql", K(ret), K(read_sql), K(*cur_sess), K(arg));
|
||||||
} else if (OB_FAIL(sql_proxy->read(res, read_sql.ptr()))) {
|
} else if (OB_FAIL(sql_proxy->read(res, read_sql.ptr()))) {
|
||||||
@ -217,7 +217,7 @@ int ObRpcKillSessionP::process()
|
|||||||
ret = OB_ERR_UNEXPECTED;
|
ret = OB_ERR_UNEXPECTED;
|
||||||
LOG_WARN("session mgr from gctx is NULL", K(ret));
|
LOG_WARN("session mgr from gctx is NULL", K(ret));
|
||||||
} else if (OB_FAIL(kill_session(arg, *session_mgr))) {
|
} else if (OB_FAIL(kill_session(arg, *session_mgr))) {
|
||||||
LOG_WARN("fail to kill sessoin", K(ret), K(arg));
|
LOG_WARN("fail to kill session", K(ret), K(arg));
|
||||||
ret = OB_ENTRY_NOT_EXIST == ret ? OB_UNKNOWN_CONNECTION : ret;
|
ret = OB_ENTRY_NOT_EXIST == ret ? OB_UNKNOWN_CONNECTION : ret;
|
||||||
} else {/*do nothing*/}
|
} else {/*do nothing*/}
|
||||||
|
|
||||||
|
|||||||
@ -79,7 +79,7 @@ struct ObCSVGeneralFormat {
|
|||||||
|
|
||||||
/**
|
/**
|
||||||
* @brief Fast csv general parser is mysql compatible csv parser
|
* @brief Fast csv general parser is mysql compatible csv parser
|
||||||
* It support single-byte or multi-byte seperators
|
* It support single-byte or multi-byte separators
|
||||||
* It support utf8, gbk and gb18030 character set
|
* It support utf8, gbk and gb18030 character set
|
||||||
*/
|
*/
|
||||||
class ObCSVGeneralParser
|
class ObCSVGeneralParser
|
||||||
|
|||||||
Reference in New Issue
Block a user