diff --git a/tests/parallel_test/cases.task b/tests/parallel_test/cases.task
index ed73a2742c..8cfb37a189 100644
--- a/tests/parallel_test/cases.task
+++ b/tests/parallel_test/cases.task
@@ -1382,6 +1382,8 @@
 ,,y,script,./test.sh -f tsim/stream/basic2.sim
 ,,y,script,./test.sh -f tsim/stream/basic3.sim
 ,,y,script,./test.sh -f tsim/stream/basic4.sim
+,,y,script,./test.sh -f tsim/stream/basic5.sim
+,,y,script,./test.sh -f tsim/stream/tag.sim
 ,,y,script,./test.sh -f tsim/stream/snodeCheck.sim
 ,,y,script,./test.sh -f tsim/stream/concurrentcheckpt.sim
 ,,y,script,./test.sh -f tsim/stream/checkpointInterval0.sim
diff --git a/tests/script/tsim/stream/tag.sim b/tests/script/tsim/stream/tag.sim
new file mode 100644
index 0000000000..f293f4ac05
--- /dev/null
+++ b/tests/script/tsim/stream/tag.sim
@@ -0,0 +1,110 @@
+system sh/stop_dnodes.sh
+system sh/deploy.sh -n dnode1 -i 1
+system sh/exec.sh -n dnode1 -s start
+
+sleep 100
+sql connect
+
+print step1
+print =============== create database
+sql create database test vgroups 2;
+sql use test;
+
+sql create table st1(ts timestamp, a int, b int , c int, d double) tags(x int);
+sql create table t1 using st1 tags(1);
+sql create table t2 using st1 tags(2);
+sql create stream streams1 trigger at_once IGNORE EXPIRED 1 IGNORE UPDATE 0 WATERMARK 100s into streamt as select  _wstart as s, count(*) c1 from st1 where x>=2 interval(60s) ;
+
+run tsim/stream/checkTaskStatus.sim
+
+
+sql insert into t2 values(1648791213000,0,1,1,1.0);
+sql insert into t2 values(1648791213001,9,2,2,1.1);
+sql insert into t2 values(1648791213009,0,3,3,1.0);
+
+sql insert into t1 values(1648791223000,0,1,1,1.0);
+sql insert into t1 values(1648791223001,9,2,2,1.1);
+sql insert into t1 values(1648791223009,0,3,3,1.0);
+
+sleep 300
+
+sql select * from streamt;
+if $data01 != 3 then
+  return -1
+endi
+
+sql alter table t1 set tag x=3;
+
+sql insert into t1 values(1648791233000,0,1,1,1.0);
+sql insert into t1 values(1648791233001,9,2,2,1.1);
+sql insert into t1 values(1648791233009,0,3,3,1.0);
+
+sleep 1000
+sql select * from streamt;
+
+if $data01 != 6 then
+  return -1
+endi
+
+sql alter table t1 set tag x=1;
+sql alter table t2 set tag x=1;
+
+sql insert into t1 values(1648791243000,0,1,1,1.0);
+sql insert into t1 values(1648791243001,9,2,2,1.1);
+
+
+sql select * from streamt;
+if $data01 != 6 then
+  return -1
+endi
+
+#$loop_count = 0
+#loop2:
+#
+#sleep 300
+#print 1 sql select * from streamt;
+#sql select * from streamt;
+#
+#print $data00 $data01 $data02 $data03
+#print $data10 $data11 $data12 $data13
+#
+#$loop_count = $loop_count + 1
+#if $loop_count == 10 then
+#  return -1
+#endi
+#
+## row 0
+#if $data01 != 3 then
+#  print ======data01=$data01
+#  goto loop2
+#endi
+#
+#if $data02 != 6 then
+#  print ======data02=$data02
+#  goto loop2
+#endi
+#
+#if $data03 != 3 then
+#  print ======data03=$data03
+#  goto loop2
+#endi
+#
+## row 1
+#if $data11 != 3 then
+#  print ======data11=$data11
+#  goto loop2
+#endi
+#
+#if $data12 != 6 then
+#  print ======data12=$data12
+#  goto loop2
+#endi
+#
+#if $data13 != 3 then
+#  print ======data13=$data13
+#  goto loop2
+#endi
+#
+
+print tag end
+system sh/exec.sh -n dnode1 -s stop -x SIGINT
diff --git a/tests/script/tsim/testsuit.sim b/tests/script/tsim/testsuit.sim
index ec52b8c234..67b84c24df 100644
--- a/tests/script/tsim/testsuit.sim
+++ b/tests/script/tsim/testsuit.sim
@@ -111,6 +111,10 @@ run tsim/stream/distributeInterval0.sim
 run tsim/stream/distributeSession0.sim
 run tsim/stream/state0.sim
 run tsim/stream/basic2.sim
+run tsim/stream/basic3.sim
+run tsim/stream/basic4.sim
+run tsim/stream/basic5.sim
+run tsim/stream/tag.sim
 run tsim/stream/concurrentcheckpt.sim
 run tsim/insert/basic1.sim
 run tsim/insert/commit-merge0.sim