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

interp only support force window close

This commit is contained in:
54liuyao 2024-10-17 17:29:57 +08:00
parent e825d74213
commit 0e2fe1554b
2 changed files with 31 additions and 25 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
source/libs/parser/src/parTranslater.c
View File

@ -10659,6 +10659,11 @@ static int32_t checkStreamQuery(STranslateContext* pCxt, SCreateStreamStmt* pStm
}
if (pSelect->hasInterpFunc) {
// Temporary code
if (pStmt->pOptions->triggerType != STREAM_TRIGGER_FORCE_WINDOW_CLOSE) {
return generateSyntaxErrMsgExt(&pCxt->msgBuf, TSDB_CODE_PAR_INVALID_STREAM_QUERY,
"Stream interp function only support force window close");
}
if (pStmt->pOptions->triggerType == STREAM_TRIGGER_FORCE_WINDOW_CLOSE) {
if (pStmt->pOptions->fillHistory) {
return generateSyntaxErrMsgExt(&pCxt->msgBuf, TSDB_CODE_PAR_INVALID_STREAM_QUERY,

51
tests/parallel_test/cases.task
View File

@ -1364,32 +1364,33 @@
,,y,script,./test.sh -f tsim/stream/sliding.sim
,,y,script,./test.sh -f tsim/stream/state0.sim
,,y,script,./test.sh -f tsim/stream/state1.sim
,,y,script,./test.sh -f tsim/stream/streamInterpDelete0.sim
,,y,script,./test.sh -f tsim/stream/streamInterpDelete1.sim
,,y,script,./test.sh -f tsim/stream/streamInterpDelete2.sim
,,y,script,./test.sh -f tsim/stream/streamInterpError.sim
#,,y,script,./test.sh -f tsim/stream/streamInterpDelete0.sim
#,,y,script,./test.sh -f tsim/stream/streamInterpDelete1.sim
#,,y,script,./test.sh -f tsim/stream/streamInterpDelete2.sim
#,,y,script,./test.sh -f tsim/stream/streamInterpError.sim
,,y,script,./test.sh -f tsim/stream/streamInterpForceWindowClose.sim
,,y,script,./test.sh -f tsim/stream/streamInterpHistory.sim
,,y,script,./test.sh -f tsim/stream/streamInterpHistory1.sim
,,y,script,./test.sh -f tsim/stream/streamInterpLarge.sim
,,y,script,./test.sh -f tsim/stream/streamInterpLinear0.sim
,,y,script,./test.sh -f tsim/stream/streamInterpNext0.sim
,,y,script,./test.sh -f tsim/stream/streamInterpOther.sim
,,y,script,./test.sh -f tsim/stream/streamInterpOther1.sim
,,y,script,./test.sh -f tsim/stream/streamInterpPartitionBy0.sim
,,y,script,./test.sh -f tsim/stream/streamInterpPrev0.sim
,,y,script,./test.sh -f tsim/stream/streamInterpPrev1.sim
,,y,script,./test.sh -f tsim/stream/streamInterpPrimaryKey0.sim
,,y,script,./test.sh -f tsim/stream/streamInterpPrimaryKey1.sim
,,y,script,./test.sh -f tsim/stream/streamInterpPrimaryKey2.sim
,,y,script,./test.sh -f tsim/stream/streamInterpPrimaryKey3.sim
,,y,script,./test.sh -f tsim/stream/streamInterpUpdate.sim
,,y,script,./test.sh -f tsim/stream/streamInterpUpdate1.sim
,,y,script,./test.sh -f tsim/stream/streamInterpValue0.sim
,,y,script,./test.sh -f tsim/stream/streamPrimaryKey0.sim
,,y,script,./test.sh -f tsim/stream/streamPrimaryKey1.sim
,,y,script,./test.sh -f tsim/stream/streamPrimaryKey2.sim
,,y,script,./test.sh -f tsim/stream/streamPrimaryKey3.sim
,,y,script,./test.sh -f tsim/stream/streamInterpForceWindowClose1.sim
#,,y,script,./test.sh -f tsim/stream/streamInterpHistory.sim
#,,y,script,./test.sh -f tsim/stream/streamInterpHistory1.sim
#,,y,script,./test.sh -f tsim/stream/streamInterpLarge.sim
#,,y,script,./test.sh -f tsim/stream/streamInterpLinear0.sim
#,,y,script,./test.sh -f tsim/stream/streamInterpNext0.sim
#,,y,script,./test.sh -f tsim/stream/streamInterpOther.sim
#,,y,script,./test.sh -f tsim/stream/streamInterpOther1.sim
#,,y,script,./test.sh -f tsim/stream/streamInterpPartitionBy0.sim
#,,y,script,./test.sh -f tsim/stream/streamInterpPrev0.sim
#,,y,script,./test.sh -f tsim/stream/streamInterpPrev1.sim
#,,y,script,./test.sh -f tsim/stream/streamInterpPrimaryKey0.sim
#,,y,script,./test.sh -f tsim/stream/streamInterpPrimaryKey1.sim
#,,y,script,./test.sh -f tsim/stream/streamInterpPrimaryKey2.sim
#,,y,script,./test.sh -f tsim/stream/streamInterpPrimaryKey3.sim
#,,y,script,./test.sh -f tsim/stream/streamInterpUpdate.sim
#,,y,script,./test.sh -f tsim/stream/streamInterpUpdate1.sim
#,,y,script,./test.sh -f tsim/stream/streamInterpValue0.sim
#,,y,script,./test.sh -f tsim/stream/streamPrimaryKey0.sim
#,,y,script,./test.sh -f tsim/stream/streamPrimaryKey1.sim
#,,y,script,./test.sh -f tsim/stream/streamPrimaryKey2.sim
#,,y,script,./test.sh -f tsim/stream/streamPrimaryKey3.sim
,,y,script,./test.sh -f tsim/stream/streamTwaError.sim
,,y,script,./test.sh -f tsim/stream/streamTwaFwcFill.sim
,,y,script,./test.sh -f tsim/stream/streamTwaFwcFillPrimaryKey.sim