diff --git a/src/client/src/tscStream.c b/src/client/src/tscStream.c index d7829c5859ffaf497341fae7e8aa02713f7895f5..3a3ddc80f6d2c2aa508f2f5420f21cd069cc825a 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 7a270bb368ae1be7a0aae9ca8d869ac0b09a21ab..3a338bb232dda37908610cfc2e643133e5e3b79e 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;