From 3fdb1f4b7cd87fa51f4db8c3043fa43a0e4eceb5 Mon Sep 17 00:00:00 2001
From: 54liuyao <54liuyao@163.com>
Date: Mon, 28 Oct 2024 13:18:59 +0800
Subject: [PATCH] add stream check

---
 source/libs/parser/src/parTranslater.c      | 7 +++++++
 tests/script/tsim/stream/streamTwaError.sim | 2 ++
 2 files changed, 9 insertions(+)

diff --git a/source/libs/parser/src/parTranslater.c b/source/libs/parser/src/parTranslater.c
index be9515e450..47181f8ce1 100755
--- a/source/libs/parser/src/parTranslater.c
+++ b/source/libs/parser/src/parTranslater.c
@@ -11008,6 +11008,13 @@ static int32_t checkStreamQuery(STranslateContext* pCxt, SCreateStreamStmt* pStm
         }
       }
     }
+
+    if ((SRealTableNode*)pSelect->pFromTable && ((SRealTableNode*)pSelect->pFromTable)->pMeta &&
+        TSDB_SUPER_TABLE == ((SRealTableNode*)pSelect->pFromTable)->pMeta->tableType &&
+        !hasTbnameFunction(pSelect->pPartitionByList)) {
+      return generateSyntaxErrMsgExt(&pCxt->msgBuf, TSDB_CODE_PAR_INVALID_STREAM_QUERY,
+                                     "When trigger was force window close, Super table must patitioned by table name");
+    }
   }
 
   if (NULL != pSelect->pGroupByList) {
diff --git a/tests/script/tsim/stream/streamTwaError.sim b/tests/script/tsim/stream/streamTwaError.sim
index 625b5840c9..cda5fa9c4b 100644
--- a/tests/script/tsim/stream/streamTwaError.sim
+++ b/tests/script/tsim/stream/streamTwaError.sim
@@ -29,6 +29,8 @@ sql_error create stream streams9 trigger at_once IGNORE EXPIRED 1 IGNORE UPDATE
 sql_error create stream streams10 trigger force_window_close IGNORE EXPIRED 1 IGNORE UPDATE 1 into  streamt10 as select _wstart, sum(a) from st partition by tbname,ta interval(2s) SLIDING(1s);
 sql create stream streams11 trigger force_window_close IGNORE EXPIRED 1 IGNORE UPDATE 1 into  streamt11 as select _wstart, avg(a) from st partition by tbname,ta interval(2s) SLIDING(2s);
 
+sql_error create stream streams10 trigger force_window_close IGNORE EXPIRED 1 IGNORE UPDATE 1 into  streamt10 as select _wstart, sum(a) from st interval(2s);
+
 print end
 
 system sh/exec.sh -n dnode1 -s stop -x SIGINT