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

fix direct load retry policy

Browse Source
This commit is contained in:
suz-yang 2024-06-17 08:26:44 +00:00 committed by ob-robot
parent f19ffe5e35
commit 8632ba2a98
1 changed files with 8 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
src/observer/mysql/ob_query_retry_ctrl.cpp
View File

@ -300,24 +300,18 @@ public:
v.retry_type_ = RETRY_TYPE_NONE;
}
v.no_more_test_ = true;
} else if (stmt::T_LOAD_DATA == v.result_.get_stmt_type()) {
if (is_load_local(v)) {
v.client_ret_ = err;
v.retry_type_ = RETRY_TYPE_NONE;
v.no_more_test_ = true;
} else if (is_direct_load(v)) {
if (is_direct_load_retry_err(err)) {
try_packet_retry(v);
} else {
v.client_ret_ = err;
v.retry_type_ = RETRY_TYPE_NONE;
}
v.no_more_test_ = true;
} else if (is_direct_load(v) && !is_load_local(v)) {
if (is_direct_load_retry_err(err)) {
try_packet_retry(v);
} else {
v.client_ret_ = err;
v.retry_type_ = RETRY_TYPE_NONE;
v.no_more_test_ = true;
}
v.no_more_test_ = true;
} else if (stmt::T_LOAD_DATA == v.result_.get_stmt_type()) {
v.client_ret_ = err;
v.retry_type_ = RETRY_TYPE_NONE;
v.no_more_test_ = true;
}
}
};