commit
ec143691ef
|
@ -529,8 +529,6 @@ int32_t loadRemoteDataCallback(void* param, SDataBuf* pMsg, int32_t code) {
|
||||||
}
|
}
|
||||||
|
|
||||||
int32_t index = pWrapper->sourceIndex;
|
int32_t index = pWrapper->sourceIndex;
|
||||||
int64_t* pRpcHandle = taosArrayGet(pExchangeInfo->pFetchRpcHandles, index);
|
|
||||||
*pRpcHandle = -1;
|
|
||||||
SSourceDataInfo* pSourceDataInfo = taosArrayGet(pExchangeInfo->pSourceDataInfo, index);
|
SSourceDataInfo* pSourceDataInfo = taosArrayGet(pExchangeInfo->pSourceDataInfo, index);
|
||||||
if (!pSourceDataInfo) {
|
if (!pSourceDataInfo) {
|
||||||
return terrno;
|
return terrno;
|
||||||
|
|
Loading…
Reference in New Issue