diff --git a/src/storage/ddl/ob_complement_data_task.cpp b/src/storage/ddl/ob_complement_data_task.cpp index b27601b61d..a0b032797d 100644 --- a/src/storage/ddl/ob_complement_data_task.cpp +++ b/src/storage/ddl/ob_complement_data_task.cpp @@ -158,7 +158,7 @@ int ObComplementDataParam::split_task_ranges( ObArrayArray multi_range_split_array; ObParallelBlockRangeTaskParams params; params.parallelism_ = hint_parallelism; - params.expected_task_load_ = tablet_size / 1024 / 1024; + params.expected_task_load_ = tablet_size / 1024 / 1024 <= 0 ? sql::OB_EXPECTED_TASK_LOAD : tablet_size / 1024 / 1024; if (OB_FAIL(ranges.push_back(range))) { LOG_WARN("push back range failed", K(ret)); } else if (OB_FAIL(tablet_service->get_multi_ranges_cost(tablet_id, diff --git a/src/storage/ddl/ob_tablet_ddl_kv_mgr.cpp b/src/storage/ddl/ob_tablet_ddl_kv_mgr.cpp index d90d8fbcc9..6f6b952de2 100644 --- a/src/storage/ddl/ob_tablet_ddl_kv_mgr.cpp +++ b/src/storage/ddl/ob_tablet_ddl_kv_mgr.cpp @@ -309,7 +309,7 @@ int ObTabletDDLKvMgr::wait_ddl_merge_success(const SCN &start_scn, const SCN &co LOG_WARN("check status failed", K(ret)); } else if (OB_FAIL(schedule_ddl_merge_task(start_scn, commit_scn, false/*is_replay*/, table_id, ddl_task_id))) { if (OB_EAGAIN == ret) { - ob_usleep(10L * 1000L); + ob_usleep(100L); // 100us. ret = OB_SUCCESS; // retry } else { LOG_WARN("commit ddl log failed", K(ret), K(start_scn), K(commit_scn), K(ls_id_), K(tablet_id_));