From 4cd1d75a416149eaf1f1b6e1910f138422f1ac2a Mon Sep 17 00:00:00 2001 From: dapan1121 Date: Wed, 23 Mar 2022 18:53:25 +0800 Subject: [PATCH] feature/scheduler --- source/libs/scheduler/src/scheduler.c | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/source/libs/scheduler/src/scheduler.c b/source/libs/scheduler/src/scheduler.c index ca471326e0..5a1a8581b0 100644 --- a/source/libs/scheduler/src/scheduler.c +++ b/source/libs/scheduler/src/scheduler.c @@ -1143,14 +1143,13 @@ int32_t schHandleHbCallback(void *param, const SDataBuf *pMsg, int32_t code) { } SSchedulerHbRsp rsp = {0}; - - SSchHbCallbackParam *pParam = (SSchHbCallbackParam *)param; - if (tDeserializeSSchedulerHbRsp(pMsg->pData, pMsg->len, &rsp)) { qError("invalid hb rsp msg, size:%d", pMsg->len); SCH_ERR_RET(TSDB_CODE_QRY_INVALID_INPUT); } + SSchTaskCallbackParam *pParam = (SSchTaskCallbackParam *)param; + SSchTrans trans = {0}; trans.transInst = pParam->transport; trans.transHandle = pMsg->handle;