From cacc7364d7677da08159ae8b04fc36da81321513 Mon Sep 17 00:00:00 2001
From: 54liuyao <54liuyao@163.com>
Date: Sat, 21 May 2022 15:11:23 +0800
Subject: [PATCH] fix(stream): avoid check data update for tmq

---
 source/libs/executor/src/scanoperator.c | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git a/source/libs/executor/src/scanoperator.c b/source/libs/executor/src/scanoperator.c
index 4e27b6ac4f..d4225caa71 100644
--- a/source/libs/executor/src/scanoperator.c
+++ b/source/libs/executor/src/scanoperator.c
@@ -972,9 +972,10 @@ SOperatorInfo* createStreamScanOperatorInfo(void* streamReadHandle, void* pDataR
   }
 
   pInfo->primaryTsIndex = 0;                           // TODO(liuyao) get it from physical plan
-  pInfo->pUpdateInfo = updateInfoInitP(&pSTInfo->interval, 10000); // TODO(liuyao) get watermark from physical plan
-  if (pInfo->pUpdateInfo == NULL) {
-    goto _error;
+  if (pSTInfo->interval.interval > 0) {
+    pInfo->pUpdateInfo = updateInfoInitP(&pSTInfo->interval, 10000); // TODO(liuyao) get watermark from physical plan
+  } else {
+    pInfo->pUpdateInfo = NULL;
   }
 
   pInfo->readHandle     = *pHandle;