diff --git a/tests/parallel_test/cases.task b/tests/parallel_test/cases.task
index 6b9a577fd5e265d5aaefd6119dba8bc323b9abd0..dd28154176cf715fb953f177139a1ad0aac1be8b 100644
--- a/tests/parallel_test/cases.task
+++ b/tests/parallel_test/cases.task
@@ -126,7 +126,7 @@
 ,,y,system-test,./pytest.sh python3 ./test.py -f 7-tmq/dataFromTsdbNWal.py
 ,,y,system-test,./pytest.sh python3 ./test.py -f 7-tmq/dataFromTsdbNWal-multiCtb.py
 ,,y,system-test,./pytest.sh python3 ./test.py -f 7-tmq/tmq_taosx.py
-,,y,system-test,./pytest.sh python3 ./test.py -f 7-tmq/tmq_offset.py
+,,n,system-test,python3 ./test.py -f 7-tmq/tmq_offset.py
 ,,y,system-test,./pytest.sh python3 ./test.py -f 7-tmq/raw_block_interface_test.py
 ,,y,system-test,./pytest.sh python3 ./test.py -f 7-tmq/stbTagFilter-multiCtb.py
 ,,y,system-test,./pytest.sh python3 ./test.py -f 7-tmq/tmqSubscribeStb-r3.py -N 5
diff --git a/tests/system-test/7-tmq/tmqParamsTest.py b/tests/system-test/7-tmq/tmqParamsTest.py
index 0fc7a6cdd98613e684776f6abc3b9077149b6254..ff7c70bcd285c7ce9340576b584756d8d2950d3e 100644
--- a/tests/system-test/7-tmq/tmqParamsTest.py
+++ b/tests/system-test/7-tmq/tmqParamsTest.py
@@ -131,7 +131,7 @@ class TDTestCase:
                         if snapshot_value == "true":
                             if offset_value != "earliest" and offset_value != "":
                                 if offset_value == "latest":
-                                    offset_value_list = list(map(lambda x: int(x[-2].replace("wal:", "").replace(offset_value, "0")), subscription_info))
+                                    offset_value_list = list(map(lambda x: int(x[-2].replace("wal:", "").replace("earliest", "0").replace("latest", "0").replace(offset_value, "0")), subscription_info))
                                     tdSql.checkEqual(sum(offset_value_list) >= 0, True)
                                     rows_value_list  = list(map(lambda x: int(x[-1]), subscription_info))
                                     tdSql.checkEqual(sum(rows_value_list), expected_res)
@@ -154,7 +154,7 @@ class TDTestCase:
                                     tdSql.checkEqual(rows_value_list, [None]*len(subscription_info))
                         else:
                             if offset_value != "none":
-                                offset_value_list = list(map(lambda x: int(x[-2].replace("wal:", "").replace(offset_value, "0")), subscription_info))
+                                offset_value_list = list(map(lambda x: int(x[-2].replace("wal:", "").replace("earliest", "0").replace("latest", "0").replace(offset_value, "0")), subscription_info))
                                 tdSql.checkEqual(sum(offset_value_list) >= 0, True)
                                 rows_value_list  = list(map(lambda x: int(x[-1]), subscription_info))
                                 tdSql.checkEqual(sum(rows_value_list), expected_res)
diff --git a/tests/system-test/7-tmq/tmq_offset.py b/tests/system-test/7-tmq/tmq_offset.py
index 33d36eda71b0ffa195ed799256553f8c585db6bc..6453f452c61be3cbf55f3e518bbc8d8e5d61f604 100644
--- a/tests/system-test/7-tmq/tmq_offset.py
+++ b/tests/system-test/7-tmq/tmq_offset.py
@@ -26,7 +26,7 @@ class TDTestCase:
         cmdStr1 = '%s/build/bin/taosBenchmark -i 50 -B 1 -t 1000 -n 100000 -y &'%(buildPath)
         tdLog.info(cmdStr1)
         os.system(cmdStr1)
-        time.sleep(10)
+        time.sleep(15)
 
         cmdStr2 = '%s/build/bin/tmq_offset_test &'%(buildPath)
         tdLog.info(cmdStr2)
diff --git a/utils/test/c/tmq_offset_test.c b/utils/test/c/tmq_offset_test.c
index cecbd615d111c54c6f93cb91a990d35668cab83b..6be9b38979edb32298ec71efbfa76d7b2dbcc720 100644
--- a/utils/test/c/tmq_offset_test.c
+++ b/utils/test/c/tmq_offset_test.c
@@ -266,7 +266,7 @@ void test_ts3756(TAOS* pConn){
   int32_t numOfAssign = 0;
 
   while (1) {
-    printf("start to poll\n");
+//    printf("start to poll\n");
 
     pRes = tmq_consumer_poll(tmq, timeout);
     if (pRes) {