adj op

3e3c8ecc · liuyao · 85ec4e55 · 3e3c8ecc
显示空白变更内容
内联并排

Showing with 1 addition and 1 deletion

source/libs/executor/src/streamtimewindowoperator.c source/libs/executor/src/streamtimewindowoperator.c +1 -1

未找到文件。
--- a/source/libs/executor/src/streamtimewindowoperator.c
+++ b/source/libs/executor/src/streamtimewindowoperator.c
@@ -3236,7 +3236,7 @@ static void doStreamMidIntervalAggImpl(SOperatorInfo* pOperator, SSDataBlock* pS
        .ts = pResult->win.skey,
        .groupId = groupId,
    };
-    if (pInfo->twAggSup.calTrigger == STREAM_TRIGGER_AT_ONCE && pUpdatedMap) {
+    if (pInfo->twAggSup.calTrigger == STREAM_TRIGGER_AT_ONCE) {
      saveWinResult(&key, pResPos, pUpdatedMap);
    }