From 699c14e78104345dcc9740fdbce8febfcf0893ad Mon Sep 17 00:00:00 2001
From: dapan1121 <wpan@taosdata.com>
Date: Thu, 23 Nov 2023 16:51:07 +0800
Subject: [PATCH] fix: slow down report when error occurs

---
 source/client/src/clientEnv.c                   | 3 +++
 source/dnode/mgmt/mgmt_dnode/src/dmWorker.c     | 3 +++
 source/libs/executor/src/dynqueryctrloperator.c | 6 +++---
 3 files changed, 9 insertions(+), 3 deletions(-)

diff --git a/source/client/src/clientEnv.c b/source/client/src/clientEnv.c
index da24bc0a3b..212c42125e 100644
--- a/source/client/src/clientEnv.c
+++ b/source/client/src/clientEnv.c
@@ -555,6 +555,9 @@ static void *tscCrashReportThreadFp(void *param) {
         if (pFile) {
           taosReleaseCrashLogFile(pFile, false);
           pFile = NULL;
+
+          taosMsleep(sleepTime);
+          loopTimes = 0;
           continue;
         }
       } else {
diff --git a/source/dnode/mgmt/mgmt_dnode/src/dmWorker.c b/source/dnode/mgmt/mgmt_dnode/src/dmWorker.c
index 18da1d638c..d6bdaf51bc 100644
--- a/source/dnode/mgmt/mgmt_dnode/src/dmWorker.c
+++ b/source/dnode/mgmt/mgmt_dnode/src/dmWorker.c
@@ -127,6 +127,9 @@ static void *dmCrashReportThreadFp(void *param) {
         if (pFile) {
           taosReleaseCrashLogFile(pFile, false);
           pFile = NULL;
+
+          taosMsleep(sleepTime);
+          loopTimes = 0;
           continue;
         }
       } else {
diff --git a/source/libs/executor/src/dynqueryctrloperator.c b/source/libs/executor/src/dynqueryctrloperator.c
index 8fc46e0239..9e7f1144f8 100755
--- a/source/libs/executor/src/dynqueryctrloperator.c
+++ b/source/libs/executor/src/dynqueryctrloperator.c
@@ -503,15 +503,15 @@ static void seqJoinLaunchNewRetrieveImpl(SOperatorInfo* pOperator, SSDataBlock**
     T_LONG_JMP(pOperator->pTaskInfo->env, pOperator->pTaskInfo->code);
   }
 
-  qError("dynamic post task begin");
+  qDebug("%s dynamic post task begin", GET_TASKID(pOperator->pTaskInfo));
   *ppRes = pOperator->pDownstream[1]->fpSet.getNextExtFn(pOperator->pDownstream[1], pParam);
   if (*ppRes) {
     pPost->isStarted = true;
     pStbJoin->execInfo.postBlkNum++;
     pStbJoin->execInfo.postBlkRows += (*ppRes)->info.rows;
-    qError("join res block retrieved");
+    qDebug("%s join res block retrieved", GET_TASKID(pOperator->pTaskInfo));
   } else {
-    qError("Empty join res block retrieved");
+    qDebug("%s Empty join res block retrieved", GET_TASKID(pOperator->pTaskInfo));
   }
 }