未验证 提交 bb5af2cc 编写于 作者: H Haojun Liao 提交者: GitHub

Merge pull request #21622 from taosdata/fix/TD-24571

semi interval op check data ts
......@@ -2345,7 +2345,7 @@ static void doStreamIntervalAggImpl(SOperatorInfo* pOperatorInfo, SSDataBlock* p
}
while (1) {
bool isClosed = isCloseWindow(&nextWin, &pInfo->twAggSup);
if ((pInfo->ignoreExpiredData && isClosed) || !inSlidingWindow(&pInfo->interval, &nextWin, &pSDataBlock->info)) {
if ((pInfo->ignoreExpiredData && isClosed && !IS_FINAL_OP(pInfo)) || !inSlidingWindow(&pInfo->interval, &nextWin, &pSDataBlock->info)) {
startPos = getNexWindowPos(&pInfo->interval, &pSDataBlock->info, tsCols, startPos, nextWin.ekey, &nextWin);
if (startPos < 0) {
break;
......
......@@ -132,12 +132,12 @@ if $loop_count == 10 then
return -1
endi
if $data01 != 1 then
if $data01 != 2 then
print =====data01=$data01
goto loop4
endi
if $data02 != 1 then
if $data02 != 2 then
print =====data02=$data02
goto loop4
endi
......
......@@ -576,13 +576,6 @@ $loop_count = 0
print step 7
loop4:
sleep 100
$loop_count = $loop_count + 1
if $loop_count == 10 then
return -1
endi
sql create database test3 vgroups 6;
sql use test3;
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册