From e667da16668ad88ef7db16cb70e941fab22abf62 Mon Sep 17 00:00:00 2001
From: Hui Li <52318143+plum-lihui@users.noreply.github.com>
Date: Fri, 24 Feb 2023 15:35:47 +0800
Subject: [PATCH] Update subscribeDb4.py

---
 tests/system-test/7-tmq/subscribeDb4.py | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git a/tests/system-test/7-tmq/subscribeDb4.py b/tests/system-test/7-tmq/subscribeDb4.py
index 7f5169361c..c14d3b27b1 100644
--- a/tests/system-test/7-tmq/subscribeDb4.py
+++ b/tests/system-test/7-tmq/subscribeDb4.py
@@ -31,7 +31,8 @@ class TDTestCase:
                 'startTs':    1640966400000,  # 2022-01-01 00:00:00.000
                 'pollDelay':  20,
                 'showMsg':    1,
-                'showRow':    1}
+                'showRow':    1,
+                'snapshot':    1}
 
     cdbName = 'cdb'
     # some parameter to consumer processor
@@ -42,7 +43,7 @@ class TDTestCase:
     ifManualCommit = 1
     groupId = 'group.id:cgrp1'
     autoCommit = 'enable.auto.commit:true'
-    autoCommitInterval = 'auto.commit.interval.ms:1000'
+    autoCommitInterval = 'auto.commit.interval.ms:100'
     autoOffset = 'auto.offset.reset:earliest'
 
     pollDelay = 20
@@ -86,7 +87,7 @@ class TDTestCase:
         tmqCom.insertConsumerInfo(self.consumerId, self.expectrowcnt,topicList,keyList,self.ifcheckdata,self.ifManualCommit)
 
         tdLog.info("start consume processor")
-        tmqCom.startTmqSimProcess(self.pollDelay,self.paraDict["dbName"],self.showMsg, self.showRow,self.cdbName)
+        tmqCom.startTmqSimProcess(self.pollDelay,self.paraDict["dbName"],self.showMsg, self.showRow,self.cdbName,0,0,self.paraDict["snapshot"])
 
         tdLog.info("After waiting for a commit notify, drop one stable")
         #time.sleep(3)
-- 
GitLab