Merge pull request #18948 from taosdata/fix/TD-21092

fix: remove sch status on timeout
taosdata · Dec 14, 2022 · 0a5ee50 · 0a5ee50
2 parents 75b7071 + e6709ca
commit 0a5ee50
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/source/libs/qworker/src/qwUtil.c b/source/libs/qworker/src/qwUtil.c
@@ -74,6 +74,8 @@ int32_t qwAddSchedulerImpl(SQWorker *mgmt, uint64_t sId, int32_t rwType) {
   SQWSchStatus newSch = {0};
   newSch.tasksHash =
       taosHashInit(mgmt->cfg.maxSchTaskNum, taosGetDefaultHashFunction(TSDB_DATA_TYPE_BINARY), false, HASH_NO_LOCK);
+  newSch.hbBrokenTs = taosGetTimestampMs();
+
   if (NULL == newSch.tasksHash) {
     QW_SCH_ELOG("taosHashInit %d failed", mgmt->cfg.maxSchTaskNum);
     QW_ERR_RET(TSDB_CODE_OUT_OF_MEMORY);