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

fix load data direct worker timeout

Browse Source
This commit is contained in:
suz-yang
2023-06-28 13:12:00 +00:00
committed by ob-robot
parent e100e6456c
commit 14936e945b
1 changed files with 0 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/sql/engine/cmd/ob_load_data_direct_impl.cpp
View File

@ -1787,7 +1787,6 @@ int ObLoadDataDirectImpl::execute(ObExecContext &ctx, ObLoadDataStmt &load_stmt)
ctx_ = &ctx; ctx_ = &ctx;
load_stmt_ = &load_stmt; load_stmt_ = &load_stmt;
const ObLoadArgument &load_args = load_stmt_->get_load_arguments(); const ObLoadArgument &load_args = load_stmt_->get_load_arguments();
const int64_t original_timeout_us = THIS_WORKER.get_timeout_ts();
int64_t total_line_count = 0; int64_t total_line_count = 0;
if (OB_SUCC(ret)) { if (OB_SUCC(ret)) {
@ -1890,7 +1889,6 @@ int ObLoadDataDirectImpl::execute(ObExecContext &ctx, ObLoadDataStmt &load_stmt)
} }
direct_loader_.destroy(); direct_loader_.destroy();
THIS_WORKER.set_timeout_ts(original_timeout_us);
return ret; return ret;
} }