From e58f667611fe6666d0f6b7b0af74b745df80ede4 Mon Sep 17 00:00:00 2001 From: yihaoDeng Date: Wed, 9 Oct 2024 20:11:21 +0800 Subject: [PATCH] add config --- source/libs/executor/src/exchangeoperator.c | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/source/libs/executor/src/exchangeoperator.c b/source/libs/executor/src/exchangeoperator.c index 767796977c..20b21acf5f 100644 --- a/source/libs/executor/src/exchangeoperator.c +++ b/source/libs/executor/src/exchangeoperator.c @@ -530,6 +530,11 @@ int32_t loadRemoteDataCallback(void* param, SDataBuf* pMsg, int32_t code) { int32_t index = pWrapper->sourceIndex; SSourceDataInfo* pSourceDataInfo = taosArrayGet(pExchangeInfo->pSourceDataInfo, index); + + int64_t* pRpcHandle = taosArrayGet(pExchangeInfo->pFetchRpcHandles, index); + asyncFreeConnById(pExchangeInfo->pTransporter, *pRpcHandle); + *pRpcHandle = -1; + if (!pSourceDataInfo) { return terrno; }