fix: fix catalog double free issue
This commit is contained in:
parent
8ce2e12423
commit
4443c7a9eb
|
@ -185,12 +185,12 @@ int32_t schHandleResponseMsg(SSchJob *pJob, SSchTask *pTask, int32_t execId, SDa
|
||||||
code = rsp->code;
|
code = rsp->code;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
SCH_UNLOCK(SCH_WRITE, &pJob->resLock);
|
|
||||||
|
|
||||||
if (taosArrayGetSize((SArray*)pJob->execRes.res) <= 0) {
|
if (taosArrayGetSize((SArray*)pJob->execRes.res) <= 0) {
|
||||||
taosArrayDestroy((SArray*)pJob->execRes.res);
|
taosArrayDestroy((SArray*)pJob->execRes.res);
|
||||||
pJob->execRes.res = NULL;
|
pJob->execRes.res = NULL;
|
||||||
}
|
}
|
||||||
|
SCH_UNLOCK(SCH_WRITE, &pJob->resLock);
|
||||||
}
|
}
|
||||||
|
|
||||||
tDecoderClear(&coder);
|
tDecoderClear(&coder);
|
||||||
|
|
Loading…
Reference in New Issue