xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

adj ci

This commit is contained in:
54liuyao 2024-10-17 15:48:52 +08:00
parent a62b5a3efd
commit 4a34ae2570
2 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
source/libs/executor/src/streamintervalsliceoperator.c
View File

@ -262,6 +262,7 @@ static int32_t doStreamIntervalSliceAggImpl(SOperatorInfo* pOperator, SSDataBloc
SWinKey prevKey = {.ts = prevPoint.winKey.win.skey, .groupId = prevPoint.winKey.groupId}; SWinKey prevKey = {.ts = prevPoint.winKey.win.skey, .groupId = prevPoint.winKey.groupId};
code = saveWinResult(&prevKey, prevPoint.pResPos, pInfo->pUpdatedMap); code = saveWinResult(&prevKey, prevPoint.pResPos, pInfo->pUpdatedMap);
QUERY_CHECK_CODE(code, lino, _end); QUERY_CHECK_CODE(code, lino, _end);
prevPoint.pLastRow->key = prevPoint.winKey.win.ekey;
} }
code = setIntervalSliceOutputBuf(&curPoint, pSup->pCtx, numOfOutput, pSup->rowEntryInfoOffset); code = setIntervalSliceOutputBuf(&curPoint, pSup->pCtx, numOfOutput, pSup->rowEntryInfoOffset);

3
tests/army/query/function/test_resinfo.py
View File

@ -26,7 +26,7 @@ from frame.sql import *
from frame.caseBase import * from frame.caseBase import *
from frame import * from frame import *
initial_hash_resinfoInt = "e739cde34b98f13dd9ad696d18f060cc" initial_hash_resinfoInt = "fbfd69d6f0aa6e015a7b5475b33ee8c8"
initial_hash_resinfo = "172d04aa7af0d8cd2e4d9df284079958" initial_hash_resinfo = "172d04aa7af0d8cd2e4d9df284079958"
class TDTestCase(TBase): class TDTestCase(TBase):
@ -43,6 +43,7 @@ class TDTestCase(TBase):
resinfoIntFile = etool.curFile(__file__, "../../../../source/libs/function/inc/functionResInfoInt.h") resinfoIntFile = etool.curFile(__file__, "../../../../source/libs/function/inc/functionResInfoInt.h")
resinfoFile = etool.curFile(__file__, "../../../../include/libs/function/functionResInfo.h") resinfoFile = etool.curFile(__file__, "../../../../include/libs/function/functionResInfo.h")
current_hash = self.get_file_hash(resinfoIntFile) current_hash = self.get_file_hash(resinfoIntFile)
tdLog.info(current_hash)
if current_hash != initial_hash_resinfoInt: if current_hash != initial_hash_resinfoInt:
tdLog.exit(f"{resinfoIntFile} has been modified.") tdLog.exit(f"{resinfoIntFile} has been modified.")
else: else: