From c7764d44780c89e7b1f46c80e4e96dfeea3068f2 Mon Sep 17 00:00:00 2001
From: tickduan <417921451@qq.com>
Date: Fri, 28 May 2021 13:00:12 +0800
Subject: [PATCH] ltime > stime to do replace

---
 src/client/src/tscStream.c | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/client/src/tscStream.c b/src/client/src/tscStream.c
index 7e6132b7c8..2226c3d95d 100644
--- a/src/client/src/tscStream.c
+++ b/src/client/src/tscStream.c
@@ -576,7 +576,7 @@ static void tscCreateStream(void *param, TAOS_RES *res, int code) {
   // set stime with ltime if ltime > stime
   const char* dstTable = pStream->dstTable? pStream->dstTable: "";
   tscDebug(" CQ table=%s ltime is %"PRId64, dstTable, pStream->ltime);
-  if(pStream->ltime > 0 && pStream->ltime > pStream->stime) {
+  if(pStream->ltime > pStream->stime) {
     tscWarn(" CQ set stream %s stime=%"PRId64" replace with ltime=%"PRId64"  ", dstTable, pStream->stime, pStream->ltime);
     pStream->stime = pStream->ltime;
   }
-- 
GitLab