提交 7a8dd0db 编写于 作者: H Haojun Liao

refactor: update the log.

上级 dc78233f
......@@ -1280,7 +1280,7 @@ int32_t tqStartStreamTasks(STQ* pTq) {
if (pMeta->walScan > 1) {
tqDebug("vgId:%d wal read task has been launched, remain scan times:%d", vgId, pMeta->walScan);
taosWUnLockLatch(&pTq->pStreamMeta->lock);
taosWUnLockLatch(&pMeta->lock);
return 0;
}
......@@ -1294,7 +1294,7 @@ int32_t tqStartStreamTasks(STQ* pTq) {
int32_t numOfTasks = taosHashGetSize(pTq->pStreamMeta->pTasks);
tqInfo("vgId:%d start wal scan stream tasks, tasks:%d", vgId, numOfTasks);
tqDebug("vgId:%d start wal scan stream tasks, tasks:%d", vgId, numOfTasks);
initOffsetForAllRestoreTasks(pTq);
pRunReq->head.vgId = vgId;
......
......@@ -27,7 +27,7 @@ int tqStreamTasksScanWal(STQ* pTq) {
int64_t st = taosGetTimestampMs();
while (1) {
tqInfo("vgId:%d continue check if data in wal are available", vgId);
tqDebug("vgId:%d continue check if data in wal are available", vgId);
// check all restore tasks
bool allFull = true;
......@@ -50,8 +50,8 @@ int tqStreamTasksScanWal(STQ* pTq) {
}
}
double el = (taosGetTimestampMs() - st) / 1000.0;
tqInfo("vgId:%d scan wal for stream tasks completed, elapsed time:%.2f sec", vgId, el);
int64_t el = (taosGetTimestampMs() - st);
tqDebug("vgId:%d scan wal for stream tasks completed, elapsed time:%"PRId64" ms", vgId, el);
// restore wal scan flag
// atomic_store_8(&pTq->pStreamMeta->walScan, 0);
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册