diff --git a/source/common/src/cos.c b/source/common/src/cos.c index ea41afd8fb..71f0df5ebe 100644 --- a/source/common/src/cos.c +++ b/source/common/src/cos.c @@ -520,7 +520,7 @@ int32_t s3PutObjectFromFile2(const char *file, const char *object) { // div round up int seq; - uint64_t chunk_size = MULTIPART_CHUNK_SIZE >> 8; + uint64_t chunk_size = MULTIPART_CHUNK_SIZE >> 7; int totalSeq = ((contentLength + chunk_size - 1) / chunk_size); MultipartPartData partData; @@ -717,6 +717,7 @@ static SArray *getListByPrefix(const char *prefix) { return data.objectArray; } } else { + taosArrayDestroyEx(data.objectArray, s3FreeObjectKey); s3PrintError(__func__, data.status, data.err_msg); } return NULL; diff --git a/source/dnode/vnode/src/tsdb/tsdbRetention.c b/source/dnode/vnode/src/tsdb/tsdbRetention.c index bc76377597..f6888ba9cb 100644 --- a/source/dnode/vnode/src/tsdb/tsdbRetention.c +++ b/source/dnode/vnode/src/tsdb/tsdbRetention.c @@ -359,6 +359,9 @@ static int32_t tsdbDoRetentionOnFileSet(SRTNer *rtner, STFileSet *fset) { s3EvictCache(fobj->fname, fsize * 2); } */ + if (fobj->f->did.level > did.level) { + continue; + } tsdbInfo("file:%s size: %" PRId64 " do migrate from %d to %d", fobj->fname, fobj->f->size, fobj->f->did.level, did.level);