enh(s3/evict): evict cache data files for other migrated head, stt, etc.

taosdata · Aug 28, 2023 · 1961e10 · 1961e10
1 parent cd3702e
commit 1961e10
Showing 1 changed file with 11 additions and 0 deletions.
diff --git a/source/dnode/vnode/src/tsdb/tsdbRetention.c b/source/dnode/vnode/src/tsdb/tsdbRetention.c
@@ -338,6 +338,17 @@ static int32_t tsdbDoRetention2(void *arg) {
           code = tsdbMigrateDataFileS3(rtner, fobj, &did);
           TSDB_CHECK_CODE(code, lino, _exit);
         } else {
+          if (tsS3Enabled) {
+            int64_t fsize = 0;
+            if (taosStatFile(fobj->fname, &fsize, NULL, NULL) < 0) {
+              code = TAOS_SYSTEM_ERROR(terrno);
+              tsdbError("vgId:%d %s failed since file:%s stat failed, reason:%s", TD_VID(fs->tsdb->pVnode), __func__,
+                        fobj->fname, tstrerror(code));
+              TSDB_CHECK_CODE(code, lino, _exit);
+            }
+            s3EvictCache(fobj->fname, fsize * 2);
+          }
+
           code = tsdbDoMigrateFileObj(rtner, fobj, &did);
           TSDB_CHECK_CODE(code, lino, _exit);
         }