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

set extra timeout for ctas rollback if insert phase exhaust all execution time

Browse Source
This commit is contained in:
obdev
2023-07-11 12:54:27 +00:00
committed by ob-robot
parent 3a44c6db38
commit 4dd0e1e962
1 changed files with 8 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/sql/engine/cmd/ob_table_executor.cpp
View File

@ -414,6 +414,14 @@ int ObCreateTableExecutor::execute_ctas(ObExecContext &ctx,
if (OB_LIKELY(OB_SUCCESS == ret)) { if (OB_LIKELY(OB_SUCCESS == ret)) {
tmp_ret = conn->commit(); tmp_ret = conn->commit();
} else { } else {
int64_t MIN_ROLLBACK_TIMEOUT = 10 * 1000 * 1000;// 10s
int64_t origin_timeout_ts = THIS_WORKER.get_timeout_ts();
if (INT64_MAX != origin_timeout_ts &&
origin_timeout_ts < ObTimeUtility::current_time() + MIN_ROLLBACK_TIMEOUT) {
THIS_WORKER.set_timeout_ts(ObTimeUtility::current_time() + MIN_ROLLBACK_TIMEOUT);
LOG_INFO("set timeout for rollback", K(origin_timeout_ts),
K(ObTimeUtility::current_time() + MIN_ROLLBACK_TIMEOUT));
}
tmp_ret = conn->rollback(); tmp_ret = conn->rollback();
} }
if (OB_UNLIKELY(OB_SUCCESS != tmp_ret)) { if (OB_UNLIKELY(OB_SUCCESS != tmp_ret)) {