From ba4d47b8b680723748170ac2344058a7c4812d6a Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Sun, 29 Dec 2024 00:15:58 +0800 Subject: [PATCH 1/2] enh(stream): extend wait time upto 300s --- source/libs/stream/src/streamCheckStatus.c | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/source/libs/stream/src/streamCheckStatus.c b/source/libs/stream/src/streamCheckStatus.c index 118cb1cfb6..5250e96a73 100644 --- a/source/libs/stream/src/streamCheckStatus.c +++ b/source/libs/stream/src/streamCheckStatus.c @@ -18,7 +18,7 @@ #include "streamBackendRocksdb.h" #include "streamInt.h" -#define CHECK_NOT_RSP_DURATION 10 * 1000 // 10 sec +#define CHECK_NOT_RSP_DURATION 30 * 1000 // 10 sec static void processDownstreamReadyRsp(SStreamTask* pTask); static void rspMonitorFn(void* param, void* tmrId); @@ -660,7 +660,7 @@ void handleTimeoutDownstreamTasks(SStreamTask* pTask, SArray* pTimeoutList) { pInfo->timeoutRetryCount += 1; - // timeout more than 100 sec, add into node update list + // timeout more than 300 sec, add into node update list if (pInfo->timeoutRetryCount > 10) { pInfo->timeoutRetryCount = 0; @@ -674,7 +674,7 @@ void handleTimeoutDownstreamTasks(SStreamTask* pTask, SArray* pTimeoutList) { findCheckRspStatus(pInfo, *pTaskId, &p); if (p != NULL) { code = streamTaskAddIntoNodeUpdateList(pTask, p->vgId); - stDebug("s-task:%s vgId:%d downstream task:0x%x (vgId:%d) timeout more than 100sec, add into nodeUpdate list", + stDebug("s-task:%s vgId:%d downstream task:0x%x (vgId:%d) timeout more than 300sec, add into nodeUpdate list", id, vgId, p->taskId, p->vgId); } } From 0c8ac0f2ecd2b202432b4e41b626b5aeebffbf7a Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Sun, 29 Dec 2024 00:42:39 +0800 Subject: [PATCH 2/2] enh(stream): inc the timeout threshold to be 600s. --- source/libs/stream/src/streamCheckStatus.c | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/source/libs/stream/src/streamCheckStatus.c b/source/libs/stream/src/streamCheckStatus.c index 5250e96a73..f880526541 100644 --- a/source/libs/stream/src/streamCheckStatus.c +++ b/source/libs/stream/src/streamCheckStatus.c @@ -18,7 +18,7 @@ #include "streamBackendRocksdb.h" #include "streamInt.h" -#define CHECK_NOT_RSP_DURATION 30 * 1000 // 10 sec +#define CHECK_NOT_RSP_DURATION 60 * 1000 // 60 sec static void processDownstreamReadyRsp(SStreamTask* pTask); static void rspMonitorFn(void* param, void* tmrId); @@ -660,7 +660,7 @@ void handleTimeoutDownstreamTasks(SStreamTask* pTask, SArray* pTimeoutList) { pInfo->timeoutRetryCount += 1; - // timeout more than 300 sec, add into node update list + // timeout more than 600 sec, add into node update list if (pInfo->timeoutRetryCount > 10) { pInfo->timeoutRetryCount = 0; @@ -674,7 +674,7 @@ void handleTimeoutDownstreamTasks(SStreamTask* pTask, SArray* pTimeoutList) { findCheckRspStatus(pInfo, *pTaskId, &p); if (p != NULL) { code = streamTaskAddIntoNodeUpdateList(pTask, p->vgId); - stDebug("s-task:%s vgId:%d downstream task:0x%x (vgId:%d) timeout more than 300sec, add into nodeUpdate list", + stDebug("s-task:%s vgId:%d downstream task:0x%x (vgId:%d) timeout more than 600sec, add into nodeUpdate list", id, vgId, p->taskId, p->vgId); } }