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

fix fetch optimizer stat bug

Browse Source
This commit is contained in:
wangt1xiuyi
2023-08-21 12:10:17 +00:00
committed by ob-robot
parent c98250b6fd
commit 5ade28e5d4
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/share/stat/ob_opt_stat_sql_service.cpp
View File

@ -314,7 +314,7 @@ int ObOptStatSqlService::fetch_table_stat(const uint64_t tenant_id,
int ret = OB_SUCCESS; int ret = OB_SUCCESS;
ObOptTableStat stat; ObOptTableStat stat;
stat.set_table_id(key.get_table_id()); stat.set_table_id(key.get_table_id());
ObSQLClientRetryWeak sql_client_retry_weak(mysql_proxy_); ObSQLClientRetryWeak sql_client_retry_weak(mysql_proxy_, false, OB_INVALID_TIMESTAMP, false);
SMART_VAR(ObMySQLProxy::MySQLResult, res) { SMART_VAR(ObMySQLProxy::MySQLResult, res) {
sqlclient::ObMySQLResult *result = NULL; sqlclient::ObMySQLResult *result = NULL;
ObSqlString sql; ObSqlString sql;
@ -1263,7 +1263,7 @@ int ObOptStatSqlService::fetch_column_stat(const uint64_t tenant_id,
ret = OB_ERR_UNEXPECTED; ret = OB_ERR_UNEXPECTED;
LOG_WARN("get unexpected error", K(key_col_stats), K(ret)); LOG_WARN("get unexpected error", K(key_col_stats), K(ret));
} else { } else {
ObSQLClientRetryWeak sql_client_retry_weak(mysql_proxy_); ObSQLClientRetryWeak sql_client_retry_weak(mysql_proxy_, false, OB_INVALID_TIMESTAMP, false);
SMART_VAR(ObMySQLProxy::MySQLResult, res) { SMART_VAR(ObMySQLProxy::MySQLResult, res) {
sqlclient::ObMySQLResult *result = NULL; sqlclient::ObMySQLResult *result = NULL;
ObSqlString sql; ObSqlString sql;
@ -1987,7 +1987,7 @@ int ObOptStatSqlService::fetch_table_rowcnt(const uint64_t tenant_id,
} else { } else {
SMART_VAR(ObMySQLProxy::MySQLResult, proxy_result) { SMART_VAR(ObMySQLProxy::MySQLResult, proxy_result) {
sqlclient::ObMySQLResult *client_result = NULL; sqlclient::ObMySQLResult *client_result = NULL;
ObSQLClientRetryWeak sql_client_retry_weak(mysql_proxy_); ObSQLClientRetryWeak sql_client_retry_weak(mysql_proxy_, false, OB_INVALID_TIMESTAMP, false);
if (OB_FAIL(sql_client_retry_weak.read(proxy_result, tenant_id, raw_sql.ptr()))) { if (OB_FAIL(sql_client_retry_weak.read(proxy_result, tenant_id, raw_sql.ptr()))) {
LOG_WARN("failed to execute sql", K(ret), K(raw_sql)); LOG_WARN("failed to execute sql", K(ret), K(raw_sql));
} else if (OB_ISNULL(client_result = proxy_result.get_result())) { } else if (OB_ISNULL(client_result = proxy_result.get_result())) {