diff --git a/source/libs/parser/src/parTranslater.c b/source/libs/parser/src/parTranslater.c index edd460db08..f89cbedb01 100755 --- a/source/libs/parser/src/parTranslater.c +++ b/source/libs/parser/src/parTranslater.c @@ -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, diff --git a/tests/parallel_test/cases.task b/tests/parallel_test/cases.task index 7a464dbc93..be28b1398d 100644 --- a/tests/parallel_test/cases.task +++ b/tests/parallel_test/cases.task @@ -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