From d8093d9f21b2cc1567b12efcf43cf398c46ed837 Mon Sep 17 00:00:00 2001 From: yihaoDeng Date: Fri, 15 Dec 2023 11:47:44 +0800 Subject: [PATCH] not do chkp when pbackend not inited --- source/libs/stream/src/streamCheckpoint.c | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/source/libs/stream/src/streamCheckpoint.c b/source/libs/stream/src/streamCheckpoint.c index e5322c1b8a..cf0682f037 100644 --- a/source/libs/stream/src/streamCheckpoint.c +++ b/source/libs/stream/src/streamCheckpoint.c @@ -425,7 +425,7 @@ int32_t streamTaskUploadChkp(SStreamTask* pTask, int64_t chkpId, char* taskId) { if (type == UPLOAD_DISABLE) { return 0; } - if (pTask->pBackend == NULL) { + if (pTask == NULL || pTask->pBackend == NULL) { return 0; } SAsyncUploadArg* arg = taosMemoryCalloc(1, sizeof(SAsyncUploadArg));