From f6b5bfae9c28d915d5687340d0dd08bd6372ca65 Mon Sep 17 00:00:00 2001 From: dapan1121 Date: Wed, 23 Mar 2022 16:03:36 +0800 Subject: [PATCH] feature/scheduler --- source/libs/scheduler/src/scheduler.c | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/source/libs/scheduler/src/scheduler.c b/source/libs/scheduler/src/scheduler.c index 529f27188e..ea12ba25d7 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);