diff --git a/source/dnode/vnode/src/tq/tqScan.c b/source/dnode/vnode/src/tq/tqScan.c
index acacec27a9..e4acf49635 100644
--- a/source/dnode/vnode/src/tq/tqScan.c
+++ b/source/dnode/vnode/src/tq/tqScan.c
@@ -88,11 +88,8 @@ int32_t tqScanData(STQ* pTq, const STqHandle* pHandle, SMqDataRsp* pRsp, STqOffs
       return -1;
     }
 
-    tqDebug("consumer:0x%"PRIx64" vgId:%d tmq task executed, rows:%"PRId64", total blocks:%d", pHandle->consumerId, vgId,
-            pDataBlock->info.rows, pRsp->blockNum);
-
+    tqDebug("consumer:0x%"PRIx64" vgId:%d tmq task executed, total blocks:%d, pDataBlock:%p", pHandle->consumerId, vgId, pRsp->blockNum, pDataBlock);
     // current scan should be stopped asap, since the rebalance occurs.
-
     if (pDataBlock == NULL) {
       break;
     }
diff --git a/tests/system-test/7-tmq/subscribeStb3.py b/tests/system-test/7-tmq/subscribeStb3.py
index 33a7c506c5..ef7ca8ff5d 100644
--- a/tests/system-test/7-tmq/subscribeStb3.py
+++ b/tests/system-test/7-tmq/subscribeStb3.py
@@ -215,7 +215,8 @@ class TDTestCase:
                          parameterDict["stbName"],\
                          parameterDict["ctbNum"],\
                          parameterDict["rowsPerTbl"],\
-                         parameterDict["batchNum"])
+                         parameterDict["batchNum"],\
+                         parameterDict["startTs"])
 
         tdLog.info("create topics from stb1")
         topicFromStb1 = 'topic_stb1'
@@ -328,7 +329,8 @@ class TDTestCase:
                          parameterDict["stbName"],\
                          parameterDict["ctbNum"],\
                          parameterDict["rowsPerTbl"],\
-                         parameterDict["batchNum"])
+                         parameterDict["batchNum"],\
+                         parameterDict["startTs"])
 
         tdLog.info("create topics from stb1")
         topicFromStb1 = 'topic_stb1'
@@ -415,7 +417,8 @@ class TDTestCase:
                          parameterDict["stbName"],\
                          parameterDict["ctbNum"],\
                          parameterDict["rowsPerTbl"],\
-                         parameterDict["batchNum"])
+                         parameterDict["batchNum"],\
+                         parameterDict["startTs"])
 
         tdLog.info("create topics from stb1")
         topicFromStb1 = 'topic_stb1'
@@ -502,7 +505,8 @@ class TDTestCase:
                          parameterDict["stbName"],\
                          parameterDict["ctbNum"],\
                          parameterDict["rowsPerTbl"],\
-                         parameterDict["batchNum"])
+                         parameterDict["batchNum"],\
+                         parameterDict["startTs"])
 
         tdLog.info("create topics from stb1")
         topicFromStb1 = 'topic_stb1'