From e42caca9c2a6530df919a988f8c053bfa98f9dcc Mon Sep 17 00:00:00 2001
From: liuyao <54liuyao@163.com>
Date: Wed, 12 Apr 2023 17:39:44 +0800
Subject: [PATCH] delete some log

---
 source/libs/executor/src/scanoperator.c       |  2 +-
 source/libs/executor/src/timewindowoperator.c | 10 ++--------
 2 files changed, 3 insertions(+), 9 deletions(-)

diff --git a/source/libs/executor/src/scanoperator.c b/source/libs/executor/src/scanoperator.c
index 86f78989d1..0ad2423ca3 100644
--- a/source/libs/executor/src/scanoperator.c
+++ b/source/libs/executor/src/scanoperator.c
@@ -2151,7 +2151,7 @@ FETCH_NEXT_BLOCK:
     // record the scan action.
     pInfo->numOfExec++;
     pOperator->resultInfo.totalRows += pBlockInfo->rows;
-    printDataBlock(pInfo->pRes, "stream scan");
+    // printDataBlock(pInfo->pRes, "stream scan");
 
     qDebug("scan rows: %" PRId64, pBlockInfo->rows);
     if (pBlockInfo->rows > 0) {
diff --git a/source/libs/executor/src/timewindowoperator.c b/source/libs/executor/src/timewindowoperator.c
index 811194031b..c2d2e92c79 100644
--- a/source/libs/executor/src/timewindowoperator.c
+++ b/source/libs/executor/src/timewindowoperator.c
@@ -2400,7 +2400,6 @@ static void doStreamIntervalAggImpl(SOperatorInfo* pOperatorInfo, SSDataBlock* p
   STimeWindow nextWin = {0};
   if (IS_FINAL_OP(pInfo)) {
     nextWin = getFinalTimeWindow(ts, &pInfo->interval);
-    qDebug("===stream===final ts:%" PRId64 ", getFinalTimeWindow:%" PRId64,ts, nextWin.skey);
   } else {
     nextWin = getActiveTimeWindow(pInfo->aggSup.pResultBuf, pResultRowInfo, ts, &pInfo->interval, TSDB_ORDER_ASC);
   }
@@ -2428,7 +2427,6 @@ static void doStreamIntervalAggImpl(SOperatorInfo* pOperatorInfo, SSDataBlock* p
         if (savePullWindow(&pull, pInfo->pPullWins) == TSDB_CODE_SUCCESS) {
           int32_t size = taosArrayGetSize(pInfo->pChildren);
           addPullWindow(pInfo->pPullDataMap, &winRes, size);
-          qDebug("===stream===prepare retrive %" PRId64 ", size:%d", winRes.ts, size);
         }
       } else {
         int32_t index = -1;
@@ -2445,17 +2443,14 @@ static void doStreamIntervalAggImpl(SOperatorInfo* pOperatorInfo, SSDataBlock* p
       }
 
       if (ignore) {
-        // startPos = getNexWindowPos(&pInfo->interval, &pSDataBlock->info, tsCols, startPos, nextWin.ekey, &nextWin);
-        int32_t prevEndPos = startPos;
-        startPos = getNextQualifiedFinalWindow(&pInfo->interval, &nextWin, &pSDataBlock->info, tsCols, prevEndPos);
+        startPos = getNextQualifiedFinalWindow(&pInfo->interval, &nextWin, &pSDataBlock->info, tsCols, startPos);
         if (startPos < 0) {
           break;
         }
         continue;
       }
     }
-    
-    qDebug("===stream===final setIntervalOutputBuf:%" PRId64, nextWin.skey);
+
     int32_t code = setIntervalOutputBuf(pInfo->pState, &nextWin, &pResPos, groupId, pSup->pCtx, numOfOutput,
                                         pSup->rowEntryInfoOffset, &pInfo->aggSup);
     pResult = (SResultRow*)pResPos->pRowBuff;
@@ -2474,7 +2469,6 @@ static void doStreamIntervalAggImpl(SOperatorInfo* pOperatorInfo, SSDataBlock* p
         .groupId = groupId,
     };
     if (pInfo->twAggSup.calTrigger == STREAM_TRIGGER_AT_ONCE && pUpdatedMap) {
-       qDebug("===stream===is final%d saveWinResult:%" PRId64,  IS_FINAL_OP(pInfo), key.ts);
       saveWinResult(&key, pResPos, pUpdatedMap);
     }
 
-- 
GitLab