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

Enable part_retry for das_simple_op

Browse Source
This commit is contained in:
pe-99y 2023-09-15 07:43:57 +00:00 committed by ob-robot
parent d3b5e04d43
commit 51ef8daa35
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/sql/das/ob_das_simple_op.cpp
View File

@ -240,6 +240,7 @@ int ObDASSimpleUtils::split_multi_ranges(ObExecContext &exec_ctx,
LOG_WARN("prepare das split_multi_ranges task failed", K(ret));
} else {
split_ranges_op = static_cast<ObDASSplitRangesOp*>(task_op);
split_ranges_op->set_can_part_retry(true);
if (OB_FAIL(split_ranges_op->init(ranges, expected_task_count))) {
LOG_WARN("failed to init das split ranges op", K(ret));
} else if (OB_FAIL(das_ref.execute_all_task())) {
@ -265,6 +266,7 @@ int ObDASSimpleUtils::get_multi_ranges_cost(ObExecContext &exec_ctx,
LOG_WARN("prepare das get_multi_ranges_cost task failed", K(ret));
} else {
ranges_cost_op = static_cast<ObDASRangesCostOp*>(task_op);
ranges_cost_op->set_can_part_retry(true);
if (OB_FAIL(ranges_cost_op->init(ranges))) {
LOG_WARN("failed to init das ranges cost op", K(ret));
} else if (OB_FAIL(das_ref.execute_all_task())) {