diff --git a/source/libs/scheduler/src/scheduler.c b/source/libs/scheduler/src/scheduler.c index 529f27188e81595236ab48f6a1d2d08205450f8e..ea12ba25d7561fa0f6e3d11e46a484d2b4a6ce36 100644 --- a/source/libs/scheduler/src/scheduler.c +++ b/source/libs/scheduler/src/scheduler.c @@ -1155,7 +1155,7 @@ int32_t schHandleHbCallback(void *param, const SDataBuf *pMsg, int32_t code) { trans.transInst = pParam->transport; trans.transHandle = pMsg->handle; - SCH_RET(schUpdateHbConnection(&rsp.epId, &trans)); + SCH_ERR_RET(schUpdateHbConnection(&rsp.epId, &trans)); int32_t taskNum = (int32_t)taosArrayGetSize(rsp.taskStatus); qDebug("%d task status in hb rsp, nodeId:%d, fqdn:%s, port:%d", taskNum, rsp.epId.nodeId, rsp.epId.ep.fqdn, rsp.epId.ep.port);