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

fix(stream): update log.

This commit is contained in:
Haojun Liao 2023-09-07 10:09:05 +08:00
parent 956047a441
commit e407d7dc6b
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
source/libs/stream/src/streamQueue.c
View File

@ -180,8 +180,8 @@ int32_t streamTaskGetDataFromInputQ(SStreamTask* pTask, SStreamQueueItem** pInpu
STokenBucket* pBucket = &pTask->tokenBucket; STokenBucket* pBucket = &pTask->tokenBucket;
bool has = streamTaskHasAvailableToken(pBucket); bool has = streamTaskHasAvailableToken(pBucket);
if (!has) { // no available token in th bucket, ignore this execution if (!has) { // no available token in th bucket, ignore this execution
qInfo("s-task:%s no available token for sink, capacity:%d, rate:%d token/sec, quit", pTask->id.idStr, // qInfo("s-task:%s no available token for sink, capacity:%d, rate:%d token/sec, quit", pTask->id.idStr,
pBucket->capacity, pBucket->rate); // pBucket->capacity, pBucket->rate);
return TSDB_CODE_SUCCESS; return TSDB_CODE_SUCCESS;
} }
@ -357,6 +357,7 @@ static void fillBucket(STokenBucket* pBucket) {
} }
pBucket->fillTimestamp = now; pBucket->fillTimestamp = now;
qDebug("new token available, ts:%"PRId64, now);
} }
} }