From 5189f3d15b1aea01bd5426a327d72e6db4848f46 Mon Sep 17 00:00:00 2001 From: yihaoDeng Date: Fri, 15 Dec 2023 09:18:37 +0800 Subject: [PATCH] not do chkp when pbackend not inited --- source/libs/stream/src/streamCheckpoint.c | 3 +++ 1 file changed, 3 insertions(+) diff --git a/source/libs/stream/src/streamCheckpoint.c b/source/libs/stream/src/streamCheckpoint.c index 9458539a9d..e5322c1b8a 100644 --- a/source/libs/stream/src/streamCheckpoint.c +++ b/source/libs/stream/src/streamCheckpoint.c @@ -425,6 +425,9 @@ int32_t streamTaskUploadChkp(SStreamTask* pTask, int64_t chkpId, char* taskId) { if (type == UPLOAD_DISABLE) { return 0; } + if (pTask->pBackend == NULL) { + return 0; + } SAsyncUploadArg* arg = taosMemoryCalloc(1, sizeof(SAsyncUploadArg)); arg->type = type; arg->taskId = taosStrdup(taskId);