Update tmqDelete-1ctb.py

d8c209b4 · Hui Li · GitHub · c218e7c5 · d8c209b4
隐藏空白更改
内联并排

Showing with 2 addition and 2 deletion

tests/system-test/7-tmq/tmqDelete-1ctb.py tests/system-test/7-tmq/tmqDelete-1ctb.py +2 -2

未找到文件。
--- a/tests/system-test/7-tmq/tmqDelete-1ctb.py
+++ b/tests/system-test/7-tmq/tmqDelete-1ctb.py
@@ -238,7 +238,7 @@ class TDTestCase:

        if self.snapshot == 0:
            consumerId     = 2
-            expectrowcnt   = int(paraDict["rowsPerTbl"] * paraDict["ctbNum"])
+            expectrowcnt   = int(paraDict["rowsPerTbl"] * paraDict["ctbNum"]) * 2
        elif self.snapshot == 1:
            consumerId     = 3
            expectrowcnt   = int(paraDict["rowsPerTbl"] * paraDict["ctbNum"] * (1 + 1/4))
@@ -324,7 +324,7 @@ class TDTestCase:

        if self.snapshot == 0:
            consumerId     = 4
-            expectrowcnt   = int(paraDict["rowsPerTbl"] * paraDict["ctbNum"])
+            expectrowcnt   = int(paraDict["rowsPerTbl"] * paraDict["ctbNum"]) * 2
        elif self.snapshot == 1:
            consumerId     = 5
            expectrowcnt   = int(paraDict["rowsPerTbl"] * paraDict["ctbNum"] * (1 - 1/4 + 1/4 + 3/4))