xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

Merge pull request #29387 from taosdata/fix/cov 

refactor(stream): extend the stream checkout timeout to be 600s.
This commit is contained in:
Shengliang Guan 2024-12-29 22:16:32 +08:00 committed by GitHub
parent e53600fee2 0c8ac0f2ec
commit 2cbcf9b1d6
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
source/libs/stream/src/streamCheckStatus.c
View File

@ -18,7 +18,7 @@
#include "streamBackendRocksdb.h" #include "streamBackendRocksdb.h"
#include "streamInt.h" #include "streamInt.h"
#define CHECK_NOT_RSP_DURATION 10 * 1000 // 10 sec #define CHECK_NOT_RSP_DURATION 60 * 1000 // 60 sec
static void processDownstreamReadyRsp(SStreamTask* pTask); static void processDownstreamReadyRsp(SStreamTask* pTask);
static void rspMonitorFn(void* param, void* tmrId); static void rspMonitorFn(void* param, void* tmrId);
@ -660,7 +660,7 @@ void handleTimeoutDownstreamTasks(SStreamTask* pTask, SArray* pTimeoutList) {
pInfo->timeoutRetryCount += 1; pInfo->timeoutRetryCount += 1;
// timeout more than 100 sec, add into node update list // timeout more than 600 sec, add into node update list
if (pInfo->timeoutRetryCount > 10) { if (pInfo->timeoutRetryCount > 10) {
pInfo->timeoutRetryCount = 0; pInfo->timeoutRetryCount = 0;
@ -674,7 +674,7 @@ void handleTimeoutDownstreamTasks(SStreamTask* pTask, SArray* pTimeoutList) {
findCheckRspStatus(pInfo, *pTaskId, &p); findCheckRspStatus(pInfo, *pTaskId, &p);
if (p != NULL) { if (p != NULL) {
code = streamTaskAddIntoNodeUpdateList(pTask, p->vgId); 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 600sec, add into nodeUpdate list",
id, vgId, p->taskId, p->vgId); id, vgId, p->taskId, p->vgId);
} }
} }