commit
9978d8cbfd
|
@ -425,6 +425,9 @@ int32_t streamTaskUploadChkp(SStreamTask* pTask, int64_t chkpId, char* taskId) {
|
||||||
if (type == UPLOAD_DISABLE) {
|
if (type == UPLOAD_DISABLE) {
|
||||||
return 0;
|
return 0;
|
||||||
}
|
}
|
||||||
|
if (pTask == NULL || pTask->pBackend == NULL) {
|
||||||
|
return 0;
|
||||||
|
}
|
||||||
SAsyncUploadArg* arg = taosMemoryCalloc(1, sizeof(SAsyncUploadArg));
|
SAsyncUploadArg* arg = taosMemoryCalloc(1, sizeof(SAsyncUploadArg));
|
||||||
arg->type = type;
|
arg->type = type;
|
||||||
arg->taskId = taosStrdup(taskId);
|
arg->taskId = taosStrdup(taskId);
|
||||||
|
|
Loading…
Reference in New Issue