fix: auto trim database

aefdf916 · Hongze Cheng · d7d32559 · aefdf916
隐藏空白更改
内联并排

Showing with 7 addition and 0 deletion

source/dnode/vnode/src/vnd/vnodeSvr.c source/dnode/vnode/src/vnd/vnodeSvr.c +7 -0

未找到文件。
--- a/source/dnode/vnode/src/vnd/vnodeSvr.c
+++ b/source/dnode/vnode/src/vnd/vnodeSvr.c
@@ -611,6 +611,13 @@ static int32_t vnodeProcessDropTtlTbReq(SVnode *pVnode, int64_t version, void *p
    tqUpdateTbUidList(pVnode->pTq, tbUids, false);
  }

+  // process
+  ret = tsdbDoRetention(pVnode->pTsdb, ttlReq.timestamp);
+  if (ret) goto end;
+
+  ret = smaDoRetention(pVnode->pSma, ttlReq.timestamp);
+  if (ret) goto end;
+
 end:
  taosArrayDestroy(tbUids);
  return ret;