fix(tmq): adjust the time out value check.

989ae86a · Haojun Liao · a1682664 · 989ae86a
隐藏空白更改
内联并排

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
@@ -1943,7 +1943,7 @@ TAOS_RES* tmq_consumer_poll(tmq_t* tmq, int64_t timeout) {
      return NULL;
    }
-    if (timeout != -1) {
+    if (timeout > 0) {
      int64_t currentTime = taosGetTimestampMs();
      int64_t elapsedTime = currentTime - startTime;
      if (elapsedTime > timeout) {