From bd0168e5623b747ae01ad6b57a140db06f3dee1b Mon Sep 17 00:00:00 2001
From: yihaoDeng <cyang@taosdata.com>
Date: Wed, 14 Jun 2023 21:43:47 +0800
Subject: [PATCH] trigger checkpoint

---
 source/common/src/tglobal.c             | 2 +-
 source/dnode/mnode/impl/src/mndStream.c | 1 +
 2 files changed, 2 insertions(+), 1 deletion(-)

diff --git a/source/common/src/tglobal.c b/source/common/src/tglobal.c
index 7df467680f..092d8ef997 100644
--- a/source/common/src/tglobal.c
+++ b/source/common/src/tglobal.c
@@ -200,7 +200,7 @@ int64_t tsWalFsyncDataSizeLimit = (100 * 1024 * 1024L);
 // internal
 int32_t tsTransPullupInterval = 2;
 int32_t tsMqRebalanceInterval = 2;
-int32_t tsStreamCheckpointTickInterval = 2;
+int32_t tsStreamCheckpointTickInterval = 20;
 int32_t tsTtlUnit = 86400;
 int32_t tsTtlPushInterval = 3600;
 int32_t tsGrantHBInterval = 60;
diff --git a/source/dnode/mnode/impl/src/mndStream.c b/source/dnode/mnode/impl/src/mndStream.c
index 236bf9ed6f..fc12fe8f25 100644
--- a/source/dnode/mnode/impl/src/mndStream.c
+++ b/source/dnode/mnode/impl/src/mndStream.c
@@ -1053,6 +1053,7 @@ static int32_t mndProcessStreamDoCheckpoint(SRpcMsg *pReq) {
     code = mndProcessStreamCheckpointTrans(pMnode, pStream, vgIds, checkpointId);
     sdbRelease(pSdb, pStream);
   }
+  taosHashCleanup(vgIds);
   return 0;
 }