From a046ae912cdf5c72bcbd932a70d1a3b198943dc8 Mon Sep 17 00:00:00 2001
From: Hongqin-Li <ihongqinli@gmail.com>
Date: Thu, 5 Jan 2023 04:45:43 +0000
Subject: [PATCH] Fix unexpected zero delay schedule time

---
 src/rootserver/ddl_task/ob_ddl_scheduler.cpp | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/src/rootserver/ddl_task/ob_ddl_scheduler.cpp b/src/rootserver/ddl_task/ob_ddl_scheduler.cpp
index 841c4665a4..2e2a988662 100644
--- a/src/rootserver/ddl_task/ob_ddl_scheduler.cpp
+++ b/src/rootserver/ddl_task/ob_ddl_scheduler.cpp
@@ -312,6 +312,7 @@ void ObDDLScheduler::run1()
     ret = OB_NOT_INIT;
     LOG_WARN("not init", K(ret));
   } else {
+    const int64_t thread_cnt = TG_GET_THREAD_CNT(lib::TGDefIDs::DDLTaskExecutor3);
     int ret = OB_SUCCESS;
     ObDDLTask *task = nullptr;
     ObDDLTask *first_retry_task = nullptr;
@@ -339,7 +340,7 @@ void ObDDLScheduler::run1()
         } else {
           ObCurTraceId::set(task->get_trace_id());
           int task_ret = task->process();
-          task->calc_next_schedule_ts(task_ret, task_queue_.get_task_cnt());
+          task->calc_next_schedule_ts(task_ret, task_queue_.get_task_cnt() + thread_cnt);
           if (task->need_retry() && !has_set_stop()) {
             if (OB_FAIL(task_queue_.add_task_to_last(task))) {
               STORAGE_LOG(ERROR, "fail to add task to last, which should not happen", K(ret), K(*task));