From 5b1368db2ff93ae2354eb8a56bae4f55556d31d9 Mon Sep 17 00:00:00 2001 From: 54liuyao <54liuyao@163.com> Date: Fri, 20 Dec 2024 08:46:57 +0800 Subject: [PATCH] adj ci --- source/libs/stream/test/streamCheckPointTest.cpp | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/source/libs/stream/test/streamCheckPointTest.cpp b/source/libs/stream/test/streamCheckPointTest.cpp index 0e1d73fef8..8b15b33b2f 100644 --- a/source/libs/stream/test/streamCheckPointTest.cpp +++ b/source/libs/stream/test/streamCheckPointTest.cpp @@ -153,8 +153,9 @@ TEST(StreamTaskAlreadySendTriggerTest, AlreadySendTrigger) { int32_t downstreamNodeId = 1; int64_t sendingCheckpointId = 123; + TSKEY ts = taosGetTimestampMs(); - STaskTriggerSendInfo triggerInfo = {.sendTs = taosGetTimestampMs(), .recved = false, .nodeId = downstreamNodeId }; + STaskTriggerSendInfo triggerInfo = {.sendTs = ts, .recved = false, .nodeId = downstreamNodeId }; taosArrayPush(pTask->chkInfo.pActiveInfo->pDispatchTriggerList, &triggerInfo); pTask->chkInfo.pActiveInfo->dispatchTrigger = true; @@ -191,8 +192,9 @@ TEST(ChkptTriggerRecvMonitorHelperTest, chkptTriggerRecvMonitorHelper) { int32_t downstreamNodeId = 1; int64_t sendingCheckpointId = 123; + TSKEY ts = taosGetTimestampMs(); - STaskTriggerSendInfo triggerInfo = {.sendTs = taosGetTimestampMs(), .recved = false, .nodeId = downstreamNodeId }; + STaskTriggerSendInfo triggerInfo = {.sendTs = ts, .recved = false, .nodeId = downstreamNodeId }; taosArrayPush(pTask->chkInfo.pActiveInfo->pDispatchTriggerList, &triggerInfo); pTask->chkInfo.pActiveInfo->dispatchTrigger = true;