From 8e319d777b3f9133824a848fed8f4982c5be9255 Mon Sep 17 00:00:00 2001
From: Haojun Liao <hjliao@taosdata.com>
Date: Mon, 2 Dec 2024 20:02:55 +0800
Subject: [PATCH] test: update test cases.

---
 tests/pytest/util/dnodes.py                   | 4 ++--
 tests/system-test/8-stream/checkpoint_info.py | 3 ++-
 2 files changed, 4 insertions(+), 3 deletions(-)

diff --git a/tests/pytest/util/dnodes.py b/tests/pytest/util/dnodes.py
index 29fb52e124..8d048825d0 100644
--- a/tests/pytest/util/dnodes.py
+++ b/tests/pytest/util/dnodes.py
@@ -39,7 +39,7 @@ class TDSimClient:
             "rpcDebugFlag": "135",
             "tmrDebugFlag": "131",
             "dDebugFlag":"131",
-            "cDebugFlag": "131",
+            "cDebugFlag": "135",
             "uDebugFlag": "131",
             "jniDebugFlag": "131",
             "qDebugFlag": "135",
@@ -136,7 +136,7 @@ class TDDnode:
             "dDebugFlag": "131",
             "vDebugFlag": "131",
             "tqDebugFlag": "135",
-            "cDebugFlag": "131",
+            "cDebugFlag": "135",
             "stDebugFlag": "135",
             "smaDebugFlag": "131",
             "jniDebugFlag": "131",
diff --git a/tests/system-test/8-stream/checkpoint_info.py b/tests/system-test/8-stream/checkpoint_info.py
index 522017a702..6f39fa6fb1 100644
--- a/tests/system-test/8-stream/checkpoint_info.py
+++ b/tests/system-test/8-stream/checkpoint_info.py
@@ -21,6 +21,7 @@ from util.cluster import *
 import threading
 # should be used by -N  option
 class TDTestCase:
+    updatecfgDict = {'debugFlag': 135, 'asynclog': 0, 'checkpointinterval':60}
 
     #updatecfgDict = {'checkpointInterval': 60 ,}
     def init(self, conn, logSql, replicaVar=1):
@@ -70,7 +71,7 @@ class TDTestCase:
         while(True):
             if(self.check_vnodestate()):
                 break
-        sql = 'select task_id, node_id, checkpoint_id, checkpoint_ver from information_schema.ins_stream_tasks where `level` = "source" or `level` = "agg" and node_type == "vnode"'
+        sql = 'select task_id, node_id, checkpoint_id, checkpoint_ver from information_schema.ins_stream_tasks where `level` = "source" or `level` = "agg" and node_type = "vnode"'
         for task_id, vnode, checkpoint_id, checkpoint_ver in tdSql.getResult(sql):
             dirpath = f"{cluster.dnodes[self.vnode_dict[vnode]-1].dataDir}/vnode/vnode{vnode}/"
             info_path = self.find_checkpoint_info_file(dirpath, checkpoint_id, task_id)