From 7a8dd0db4564e30c7439dc818525db2c53fab16b Mon Sep 17 00:00:00 2001
From: Haojun Liao <hjliao@taosdata.com>
Date: Tue, 18 Apr 2023 16:08:51 +0800
Subject: [PATCH] refactor: update the log.

---
 source/dnode/vnode/src/tq/tq.c        | 4 ++--
 source/dnode/vnode/src/tq/tqRestore.c | 6 +++---
 2 files changed, 5 insertions(+), 5 deletions(-)

diff --git a/source/dnode/vnode/src/tq/tq.c b/source/dnode/vnode/src/tq/tq.c
index 60c6c3d7fb..8892291727 100644
--- a/source/dnode/vnode/src/tq/tq.c
+++ b/source/dnode/vnode/src/tq/tq.c
@@ -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;
diff --git a/source/dnode/vnode/src/tq/tqRestore.c b/source/dnode/vnode/src/tq/tqRestore.c
index 6ed74ddcc3..241c8a5ea0 100644
--- a/source/dnode/vnode/src/tq/tqRestore.c
+++ b/source/dnode/vnode/src/tq/tqRestore.c
@@ -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);
-- 
GitLab