From 19bd217573415856befb3394090fce86bd1b1e55 Mon Sep 17 00:00:00 2001 From: wangmm0220 Date: Mon, 29 Jul 2024 17:23:57 +0800 Subject: [PATCH] fix:[TD-30882]ci case error in sometimes --- source/client/src/clientMonitor.c | 1 + tests/system-test/8-stream/snode_restart_with_checkpoint.py | 4 +++- 2 files changed, 4 insertions(+), 1 deletion(-) diff --git a/source/client/src/clientMonitor.c b/source/client/src/clientMonitor.c index 40cea644fd..92a8fc3b29 100644 --- a/source/client/src/clientMonitor.c +++ b/source/client/src/clientMonitor.c @@ -489,6 +489,7 @@ static int32_t monitorReadSend(int64_t clusterId, TdFilePtr pFile, int64_t* offs SAppInstInfo* pInst = getAppInstByClusterId(clusterId); if (pInst == NULL) { tscError("failed to get app instance by clusterId:%" PRId64, clusterId); + taosMemoryFree(fileName); return terrno; } SEpSet ep = getEpSet_s(&pInst->mgmtEp); diff --git a/tests/system-test/8-stream/snode_restart_with_checkpoint.py b/tests/system-test/8-stream/snode_restart_with_checkpoint.py index 9eb8c09ca3..28875df035 100644 --- a/tests/system-test/8-stream/snode_restart_with_checkpoint.py +++ b/tests/system-test/8-stream/snode_restart_with_checkpoint.py @@ -51,7 +51,9 @@ class TDTestCase: for i in range(rowCnt): results.append(tdSql.getData(i,1)) - tdSql.query("select * from st1 order by groupid,_wstart") + sql = "select * from st1 order by groupid,_wstart" + tdSql.check_rows_loop(rowCnt, sql, loopCount=100, waitTime=0.5) + tdSql.checkRows(rowCnt) for i in range(rowCnt): data1 = tdSql.getData(i,1)