From d23c80b12fc38edd0623479047c4c4b6df8d482d Mon Sep 17 00:00:00 2001
From: liuyao <54liuyao@163.com>
Date: Wed, 21 Jun 2023 10:24:34 +0800
Subject: [PATCH] free mem

---
 source/libs/executor/src/scanoperator.c       | 4 ++--
 source/libs/stream/test/tstreamUpdateTest.cpp | 2 +-
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/source/libs/executor/src/scanoperator.c b/source/libs/executor/src/scanoperator.c
index e787e73434..1059677108 100644
--- a/source/libs/executor/src/scanoperator.c
+++ b/source/libs/executor/src/scanoperator.c
@@ -1764,7 +1764,7 @@ void streamScanOperatorDecode(void* pBuff, int32_t len, SStreamScanInfo* pInfo)
     return;
   }
 
-  void* pUpInfo = pInfo->stateStore.updateInfoInit(0, TSDB_TIME_PRECISION_MILLI, 0);
+  void* pUpInfo = taosMemoryCalloc(1, sizeof(SUpdateInfo));
   int32_t      code = pInfo->stateStore.updateInfoDeserialize(pBuff, len, pUpInfo);
   if (code == TSDB_CODE_SUCCESS) {
     pInfo->pUpdateInfo = pUpInfo;
@@ -2341,7 +2341,7 @@ void streamScanReloadState(SOperatorInfo* pOperator) {
   void*   pBuff = NULL;
   int32_t len = 0;
   pInfo->stateStore.streamStateGetInfo(pInfo->pState, STREAM_SCAN_OP_STATE_NAME, strlen(STREAM_SCAN_OP_STATE_NAME), &pBuff, &len);
-  SUpdateInfo* pUpInfo = pInfo->stateStore.updateInfoInit(0, TSDB_TIME_PRECISION_MILLI, 0);
+  SUpdateInfo* pUpInfo = taosMemoryCalloc(1, sizeof(SUpdateInfo));
   int32_t      code = pInfo->stateStore.updateInfoDeserialize(pBuff, len, pUpInfo);
   taosMemoryFree(pBuff);
   if (code == TSDB_CODE_SUCCESS && pInfo->pUpdateInfo) {
diff --git a/source/libs/stream/test/tstreamUpdateTest.cpp b/source/libs/stream/test/tstreamUpdateTest.cpp
index 18c60aff28..0e84d6b8bd 100644
--- a/source/libs/stream/test/tstreamUpdateTest.cpp
+++ b/source/libs/stream/test/tstreamUpdateTest.cpp
@@ -158,7 +158,7 @@ TEST(TD_STREAM_UPDATE_TEST, update) {
   // void   *buf = taosMemoryCalloc(1, bufLen);
   // int32_t resSize = updateInfoSerialize(buf, bufLen, pSU7);
 
-  // SUpdateInfo *pSU6 = updateInfoInit(0, TSDB_TIME_PRECISION_MILLI, 0);
+  // SUpdateInfo *pSU6 = taosMemoryCalloc(1, sizeof(SUpdateInfo));
   // int32_t      desSize = updateInfoDeserialize(buf, bufLen, pSU6);
   // GTEST_ASSERT_EQ(desSize, 0);