From 69c913dcc46b91e0477635473fd8d12775003f4d Mon Sep 17 00:00:00 2001 From: Alex Duan <417921451@qq.com> Date: Wed, 24 Nov 2021 15:49:24 +0800 Subject: [PATCH] set retry default value to 30minute --- src/client/src/tscStream.c | 2 +- src/common/src/tglobal.c | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/src/client/src/tscStream.c b/src/client/src/tscStream.c index d7829c5859..3a3ddc80f6 100644 --- a/src/client/src/tscStream.c +++ b/src/client/src/tscStream.c @@ -534,7 +534,7 @@ static void tscProcessStreamRetrieveResult(void *param, TAOS_RES *res, int numOf for(int32_t i = 0; i < numOfRows; ++i) { TAOS_ROW row = taos_fetch_row(res); if (row != NULL) { - tscDebug("0x%"PRIx64" stream:%p fetch result", pSql->self, pStream); + tscDebug("0x%"PRIx64" stream:%p fetch result row=%d", pSql->self, pStream, i); tscStreamFillTimeGap(pStream, *(TSKEY*)row[0]); pStream->stime = *(TSKEY *)row[0]; // write to another table if true diff --git a/src/common/src/tglobal.c b/src/common/src/tglobal.c index 7a270bb368..3a338bb232 100644 --- a/src/common/src/tglobal.c +++ b/src/common/src/tglobal.c @@ -102,7 +102,7 @@ int32_t tsMaxStreamComputDelay = 20000; int32_t tsFirstLaunchDelay = 10000; // the stream computing delay time after executing failed, change accordingly -int32_t tsRetryStreamCompDelay = 10 * 1000; +int32_t tsRetryStreamCompDelay = 30 * 60 * 1000; // The delayed computing ration. 10% of the whole computing time window by default. float tsStreamComputDelayRatio = 0.1f; -- GitLab