提交 6c7b3455 编写于 作者: B bf0 提交者: LINGuanRen

fix load data core when handle shuffle result

上级 c0424490
......@@ -2919,6 +2919,7 @@ int ObLoadDataSPImpl::wait_shuffle_task_return(ToolBox& box)
ret = OB_ERR_UNEXPECTED;
} else {
handle->result.reset();
handle->err_records.reuse();
}
}
......@@ -2930,7 +2931,7 @@ int ObLoadDataSPImpl::handle_returned_shuffle_task(ToolBox& box, ObShuffleTaskHa
UNUSED(box);
int ret = OB_SUCCESS;
if (OB_UNLIKELY(handle.result.task_id_ >= box.file_buf_row_num.count())) {
if (OB_UNLIKELY(handle.result.task_id_ >= box.file_buf_row_num.count() || handle.result.task_id_ < 0)) {
ret = OB_ERR_UNEXPECTED;
LOG_WARN("invalid array index", K(ret), K(handle.result.task_id_), K(box.file_buf_row_num.count()));
} else if (!box.file_appender.is_opened() && OB_FAIL(create_log_file(box))) {
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册