未验证 提交 1ba198b9 编写于 作者: S Shengliang Guan 提交者: GitHub

Merge pull request #20255 from taosdata/fix/main_bugfix_wxy

fix: the number of output lines is incorrect when the event window is used with the multiline function
...@@ -29,7 +29,7 @@ typedef struct SEventWindowOperatorInfo { ...@@ -29,7 +29,7 @@ typedef struct SEventWindowOperatorInfo {
SWindowRowsSup winSup; SWindowRowsSup winSup;
int32_t tsSlotId; // primary timestamp column slot id int32_t tsSlotId; // primary timestamp column slot id
STimeWindowAggSupp twAggSup; STimeWindowAggSupp twAggSup;
uint64_t groupId; // current group id, used to identify the data block from different groups uint64_t groupId; // current group id, used to identify the data block from different groups
SFilterInfo* pStartCondInfo; SFilterInfo* pStartCondInfo;
SFilterInfo* pEndCondInfo; SFilterInfo* pEndCondInfo;
bool inWindow; bool inWindow;
...@@ -310,6 +310,7 @@ int32_t eventWindowAggImpl(SOperatorInfo* pOperator, SEventWindowOperatorInfo* p ...@@ -310,6 +310,7 @@ int32_t eventWindowAggImpl(SOperatorInfo* pOperator, SEventWindowOperatorInfo* p
pSup->rowEntryInfoOffset, pTaskInfo); pSup->rowEntryInfoOffset, pTaskInfo);
pRes->info.rows += pInfo->pRow->numOfRows; pRes->info.rows += pInfo->pRow->numOfRows;
pInfo->pRow->numOfRows = 0;
pInfo->inWindow = false; pInfo->inWindow = false;
rowIndex += 1; rowIndex += 1;
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册