From aa2c09ef5b88c346fb0c387611181acc321ca91f Mon Sep 17 00:00:00 2001 From: yihaoDeng Date: Tue, 14 Nov 2023 18:09:00 +0800 Subject: [PATCH] rm dup data --- source/libs/stream/src/streamCheckpoint.c | 1 + 1 file changed, 1 insertion(+) diff --git a/source/libs/stream/src/streamCheckpoint.c b/source/libs/stream/src/streamCheckpoint.c index b61256371b..74c391f386 100644 --- a/source/libs/stream/src/streamCheckpoint.c +++ b/source/libs/stream/src/streamCheckpoint.c @@ -377,6 +377,7 @@ int32_t doUploadChkp(void* param) { int32_t code = 0; SArray* list = taosArrayInit(4, sizeof(void*)); + if ((code = taskDbGenChkpUploadData(arg->pTask->pBackend, arg->pTask->pMeta->bkdChkptMgt, arg->chkpId, (int8_t)(arg->type), &path, list)) != 0) { stError("s-task:%s failed to gen upload checkpoint:%" PRId64 "", arg->pTask->id.idStr, arg->chkpId);