diff --git a/src/rpc/src/tudp.c b/src/rpc/src/tudp.c index e86b1de36b2c40a81759cbd4b90c4367ac8c8d85..23265f4ca303fc98479728ec600958b119f8695a 100644 --- a/src/rpc/src/tudp.c +++ b/src/rpc/src/tudp.c @@ -299,7 +299,7 @@ void *taosTransferDataViaTcp(void *argv) { return NULL; } - if (!taosCheckHandleViaTcpValid(&handleViaTcp)) { + if (handleViaTcp.handle && !taosCheckHandleViaTcpValid(&handleViaTcp)) { tError("%s UDP server read handle via tcp invalid, handle:%" PRIu64 ", hash:%" PRIu64, pSet->label, handleViaTcp.handle, handleViaTcp.hash); taosCloseSocket(connFd);