Fix direct load handle task result swallow error code
This commit is contained in:
@ -1241,7 +1241,7 @@ int ObLoadDataDirectImpl::FileLoadExecutor::handle_all_task_result()
|
|||||||
{
|
{
|
||||||
int ret = OB_SUCCESS;
|
int ret = OB_SUCCESS;
|
||||||
TaskHandle *handle = nullptr;
|
TaskHandle *handle = nullptr;
|
||||||
while (handle_reserve_queue_.count() > 0) {
|
while (OB_SUCC(ret) && handle_reserve_queue_.count() > 0) {
|
||||||
if (OB_FAIL(handle_reserve_queue_.pop(handle))) {
|
if (OB_FAIL(handle_reserve_queue_.pop(handle))) {
|
||||||
LOG_WARN("fail to pop handle", KR(ret));
|
LOG_WARN("fail to pop handle", KR(ret));
|
||||||
} else if (OB_ISNULL(handle)) {
|
} else if (OB_ISNULL(handle)) {
|
||||||
|
|||||||
Reference in New Issue
Block a user