fix:time_wait in doAskEp

fa154172 · wmmhello · 98b74d69 · fa154172
隐藏空白更改
内联并排

Showing with 1 addition and 1 deletion

source/client/src/clientTmq.c source/client/src/clientTmq.c +1 -1

未找到文件。
--- a/source/client/src/clientTmq.c
+++ b/source/client/src/clientTmq.c
@@ -1529,8 +1529,8 @@ int32_t askEpCallbackFn(void* param, SDataBuf* pMsg, int32_t code) {
  } else {
    tscDebug("consumer:0x%" PRIx64 ", recv ep, msg epoch %d, current epoch %d, update local ep", tmq->consumerId,
             head->epoch, epoch);
-    pParam->pUserFn(tmq, code, pMsg, pParam->pParam);
  }
+  pParam->pUserFn(tmq, code, pMsg, pParam->pParam);

  taosReleaseRef(tmqMgmt.rsetId, pParam->refId);