From 34d081b1382a00103ff5c148250518af4eccc0f2 Mon Sep 17 00:00:00 2001 From: chenhaoran Date: Tue, 19 Mar 2024 16:45:28 +0800 Subject: [PATCH] add testcase of disorder and null data in tmq test --- tests/system-test/7-tmq/tmq_ts4563.py | 9 +-------- 1 file changed, 1 insertion(+), 8 deletions(-) diff --git a/tests/system-test/7-tmq/tmq_ts4563.py b/tests/system-test/7-tmq/tmq_ts4563.py index a4b739f1ab..13f510ffe6 100644 --- a/tests/system-test/7-tmq/tmq_ts4563.py +++ b/tests/system-test/7-tmq/tmq_ts4563.py @@ -51,24 +51,17 @@ class TDTestCase: try: while True: res = consumer.poll(1) - print(cnt,res) + print(res) if not res: - print("111",cnt) if cnt == 0 or cnt != 2*self.expected_affected_rows: tdLog.exit("consume error") break val = res.value() - print(val) if val is None: continue for block in val: print(block.fetchall(),len(block.fetchall())) cnt += len(block.fetchall()) - # print(cnt) - # if cnt != 3: - # tdLog.exit("consume error") - # print("polling") - finally: consumer.close()