diff --git a/tests/script/tsim/stream/streamInterpOther.sim b/tests/script/tsim/stream/streamInterpOther.sim
index 31e1e3af63..c135a31992 100644
--- a/tests/script/tsim/stream/streamInterpOther.sim
+++ b/tests/script/tsim/stream/streamInterpOther.sim
@@ -393,236 +393,4 @@ if $rows != 0 then
   goto loop3
 endi
 
-print step4
-
-sql create database test4 vgroups 4;
-sql use test4;
-
-sql create stable st(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int);
-sql create table t1 using st tags(1,1,1);
-sql create table t2 using st tags(2,2,2);
-
-sql create stable streamt4_1(ts timestamp,a varchar(10),b tinyint,c tinyint) tags(ta int,cc int,tc int);
-sql create stable streamt4_2(ts timestamp,a varchar(10),b tinyint,c tinyint) tags(ta int,cc int,tc int);
-sql create stable streamt4_3(ts timestamp,a varchar(10),b tinyint,c tinyint) tags(ta int,cc int,tc int);
-sql create stable streamt4_4(ts timestamp,a varchar(10),b tinyint,c tinyint) tags(ta int,cc int,tc int);
-sql create stable streamt4_5(ts timestamp,a varchar(10),b tinyint,c tinyint) tags(ta int,cc int,tc int);
-
-sql create stream streams4_1 trigger at_once IGNORE EXPIRED 0 IGNORE UPDATE 0 into  streamt4_1(ts, b, a) TAGS(cc) SUBTABLE(concat(concat("tbn-", tbname), "_1")) as select _irowts, interp(a), _isfilled as a1 from st partition by tbname, b as cc every(1s) fill(prev);
-sql create stream streams4_2 trigger at_once IGNORE EXPIRED 0 IGNORE UPDATE 0 into  streamt4_2(ts, b, a) TAGS(cc) SUBTABLE(concat(concat("tbn-", tbname), "_2")) as select _irowts, interp(a), _isfilled as a1 from st partition by tbname, b as cc every(1s) fill(next);
-sql create stream streams4_3 trigger at_once IGNORE EXPIRED 0 IGNORE UPDATE 0 into  streamt4_3(ts, b, a) TAGS(cc) SUBTABLE(concat(concat("tbn-", tbname), "_3")) as select _irowts, interp(a), _isfilled as a1 from st partition by tbname, b as cc every(1s) fill(linear);
-sql create stream streams4_4 trigger at_once IGNORE EXPIRED 0 IGNORE UPDATE 0 into  streamt4_4(ts, b, a) TAGS(cc) SUBTABLE(concat(concat("tbn-", tbname), "_4")) as select _irowts, interp(a), _isfilled as a1 from st partition by tbname, b as cc every(1s) fill(NULL);
-sql create stream streams4_5 trigger at_once IGNORE EXPIRED 0 IGNORE UPDATE 0 into  streamt4_5(ts, b, a) TAGS(cc) SUBTABLE(concat(concat("tbn-", tbname), "_5")) as select _irowts, interp(a), _isfilled as a1 from st partition by tbname, b as cc every(1s) fill(value,1100);
-
-run tsim/stream/checkTaskStatus.sim
-
-sql insert into t1 values(1648791217000,20000,2,3);
-
-sleep 500
-
-sql insert into t1 values(1648791212000,10000,2,3);
-
-sleep 500
-
-sql insert into t1 values(1648791215001,20,2,3);
-
-$loop_count = 0
-loop4:
-
-$loop_count = $loop_count + 1
-if $loop_count == 10 then
-  return -1
-endi
-
-sleep 300
-
-print sql select a,b from streamt4_1;
-sql select a,b from streamt4_1;
-
-if $rows != 6 then
-  print ======rows=$rows
-  goto loop4
-endi
-
-if $data00 != false then
-  print ======data00=$data00
-  goto loop4
-endi
-
-if $data01 != 16 then
-  print ======data01=$data01
-  goto loop4
-endi
-
-if $data10 != true then
-  print ======data10=$data10
-  goto loop4
-endi
-
-if $data20 != true then
-  print ======data20=$data20
-  goto loop4
-endi
-
-if $data50 != false then
-  print ======data50=$data50
-  goto loop4
-endi
-
-if $data51 != 32 then
-  print ======data51=$data51
-  goto loop4
-endi
-
-print sql select a,b from streamt4_2;
-sql select a,b from streamt4_2;
-
-if $rows != 6 then
-  print ======rows=$rows
-  goto loop4
-endi
-
-if $data00 != false then
-  print ======data00=$data00
-  goto loop4
-endi
-
-if $data01 != 16 then
-  print ======data01=$data01
-  goto loop4
-endi
-
-if $data10 != true then
-  print ======data10=$data10
-  goto loop4
-endi
-
-if $data20 != true then
-  print ======data20=$data20
-  goto loop4
-endi
-
-if $data50 != false then
-  print ======data50=$data50
-  goto loop4
-endi
-
-if $data51 != 32 then
-  print ======data51=$data51
-  goto loop4
-endi
-
-print sql select a,b from streamt4_3;
-sql select a,b from streamt4_3;
-
-if $rows != 6 then
-  print ======rows=$rows
-  goto loop4
-endi
-
-if $data00 != false then
-  print ======data00=$data00
-  goto loop4
-endi
-
-if $data01 != 16 then
-  print ======data01=$data01
-  goto loop4
-endi
-
-if $data10 != true then
-  print ======data10=$data10
-  goto loop4
-endi
-
-if $data20 != true then
-  print ======data20=$data20
-  goto loop4
-endi
-
-if $data50 != false then
-  print ======data50=$data50
-  goto loop4
-endi
-
-if $data51 != 32 then
-  print ======data51=$data51
-  goto loop4
-endi
-
-print sql select a,b from streamt4_4;
-sql select a,b from streamt4_4;
-
-if $rows != 6 then
-  print ======rows=$rows
-  goto loop4
-endi
-
-if $data00 != false then
-  print ======data00=$data00
-  goto loop4
-endi
-
-if $data01 != 16 then
-  print ======data01=$data01
-  goto loop4
-endi
-
-if $data10 != true then
-  print ======data10=$data10
-  goto loop4
-endi
-
-if $data20 != true then
-  print ======data20=$data20
-  goto loop4
-endi
-
-if $data50 != false then
-  print ======data50=$data50
-  goto loop4
-endi
-
-if $data51 != 32 then
-  print ======data51=$data51
-  goto loop4
-endi
-
-print sql select a,b from streamt4_5;
-sql select a,b from streamt4_5;
-
-if $rows != 6 then
-  print ======rows=$rows
-  goto loop4
-endi
-
-if $data00 != false then
-  print ======data00=$data00
-  goto loop4
-endi
-
-if $data01 != 16 then
-  print ======data01=$data01
-  goto loop4
-endi
-
-if $data10 != true then
-  print ======data10=$data10
-  goto loop4
-endi
-
-if $data20 != true then
-  print ======data20=$data20
-  goto loop4
-endi
-
-if $data50 != false then
-  print ======data50=$data50
-  goto loop4
-endi
-
-if $data51 != 32 then
-  print ======data51=$data51
-  goto loop4
-endi
 system sh/exec.sh -n dnode1 -s stop -x SIGINT
diff --git a/tests/script/tsim/stream/streamInterpOther1.sim b/tests/script/tsim/stream/streamInterpOther1.sim
new file mode 100644
index 0000000000..045da1ce84
--- /dev/null
+++ b/tests/script/tsim/stream/streamInterpOther1.sim
@@ -0,0 +1,335 @@
+system sh/stop_dnodes.sh
+system sh/deploy.sh -n dnode1 -i 1
+system sh/exec.sh -n dnode1 -s start
+sleep 50
+sql connect
+
+print step4
+
+sql create database test4_1 vgroups 4;
+sql use test4_1;
+
+sql create stable st(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int);
+sql create table t1 using st tags(1,1,1);
+sql create table t2 using st tags(2,2,2);
+
+sql create stable streamt4_1(ts timestamp,a varchar(10),b tinyint,c tinyint) tags(ta int,cc int,tc int);
+
+sql create stream streams4_1 trigger at_once IGNORE EXPIRED 0 IGNORE UPDATE 0 into  streamt4_1(ts, b, a) TAGS(cc) SUBTABLE(concat(concat("tbn-", tbname), "_1")) as select _irowts, interp(a), _isfilled as a1 from st partition by tbname, b as cc every(1s) fill(prev);
+
+run tsim/stream/checkTaskStatus.sim
+
+sql insert into t1 values(1648791217000,20000,2,3);
+
+sleep 500
+
+sql insert into t1 values(1648791212000,10000,2,3);
+
+sleep 500
+
+sql insert into t1 values(1648791215001,20,2,3);
+
+$loop_count = 0
+loop4_1:
+
+$loop_count = $loop_count + 1
+if $loop_count == 10 then
+  return -1
+endi
+
+sleep 300
+
+print sql select a,b from streamt4_1;
+sql select a,b from streamt4_1;
+
+if $rows != 6 then
+  print ======rows=$rows
+  goto loop4_1
+endi
+
+if $data00 != false then
+  print ======data00=$data00
+  goto loop4_1
+endi
+
+if $data01 != 16 then
+  print ======data01=$data01
+  goto loop4_1
+endi
+
+if $data10 != true then
+  print ======data10=$data10
+  goto loop4_1
+endi
+
+if $data20 != true then
+  print ======data20=$data20
+  goto loop4_1
+endi
+
+if $data50 != false then
+  print ======data50=$data50
+  goto loop4_1
+endi
+
+if $data51 != 32 then
+  print ======data51=$data51
+  goto loop4_1
+endi
+
+sql create database test4_2 vgroups 4;
+sql use test4_2;
+
+sql create stable st(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int);
+sql create table t1 using st tags(1,1,1);
+sql create table t2 using st tags(2,2,2);
+
+sql create stable streamt4_2(ts timestamp,a varchar(10),b tinyint,c tinyint) tags(ta int,cc int,tc int);
+
+sql create stream streams4_2 trigger at_once IGNORE EXPIRED 0 IGNORE UPDATE 0 into  streamt4_2(ts, b, a) TAGS(cc) SUBTABLE(concat(concat("tbn-", tbname), "_2")) as select _irowts, interp(a), _isfilled as a1 from st partition by tbname, b as cc every(1s) fill(next);
+
+run tsim/stream/checkTaskStatus.sim
+
+sql insert into t1 values(1648791217000,20000,2,3);
+
+sleep 500
+
+sql insert into t1 values(1648791212000,10000,2,3);
+
+sleep 500
+
+sql insert into t1 values(1648791215001,20,2,3);
+
+$loop_count = 0
+loop4_2:
+
+print sql select a,b from streamt4_2;
+sql select a,b from streamt4_2;
+
+if $rows != 6 then
+  print ======rows=$rows
+  goto loop4_2
+endi
+
+if $data00 != false then
+  print ======data00=$data00
+  goto loop4_2
+endi
+
+if $data01 != 16 then
+  print ======data01=$data01
+  goto loop4_2
+endi
+
+if $data10 != true then
+  print ======data10=$data10
+  goto loop4_2
+endi
+
+if $data20 != true then
+  print ======data20=$data20
+  goto loop4_2
+endi
+
+if $data50 != false then
+  print ======data50=$data50
+  goto loop4_2
+endi
+
+if $data51 != 32 then
+  print ======data51=$data51
+  goto loop4_2
+endi
+
+sql create database test4_3 vgroups 4;
+sql use test4_3;
+
+sql create stable st(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int);
+sql create table t1 using st tags(1,1,1);
+sql create table t2 using st tags(2,2,2);
+
+sql create stable streamt4_3(ts timestamp,a varchar(10),b tinyint,c tinyint) tags(ta int,cc int,tc int);
+
+sql create stream streams4_3 trigger at_once IGNORE EXPIRED 0 IGNORE UPDATE 0 into  streamt4_3(ts, b, a) TAGS(cc) SUBTABLE(concat(concat("tbn-", tbname), "_3")) as select _irowts, interp(a), _isfilled as a1 from st partition by tbname, b as cc every(1s) fill(linear);
+
+run tsim/stream/checkTaskStatus.sim
+
+sql insert into t1 values(1648791217000,20000,2,3);
+
+sleep 500
+
+sql insert into t1 values(1648791212000,10000,2,3);
+
+sleep 500
+
+sql insert into t1 values(1648791215001,20,2,3);
+
+$loop_count = 0
+loop4_3:
+
+print sql select a,b from streamt4_3;
+sql select a,b from streamt4_3;
+
+if $rows != 6 then
+  print ======rows=$rows
+  goto loop4_3
+endi
+
+if $data00 != false then
+  print ======data00=$data00
+  goto loop4_3
+endi
+
+if $data01 != 16 then
+  print ======data01=$data01
+  goto loop4_3
+endi
+
+if $data10 != true then
+  print ======data10=$data10
+  goto loop4_3
+endi
+
+if $data20 != true then
+  print ======data20=$data20
+  goto loop4_3
+endi
+
+if $data50 != false then
+  print ======data50=$data50
+  goto loop4_3
+endi
+
+if $data51 != 32 then
+  print ======data51=$data51
+  goto loop4_3
+endi
+
+sql create database test4_4 vgroups 4;
+sql use test4_4;
+
+sql create stable st(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int);
+sql create table t1 using st tags(1,1,1);
+sql create table t2 using st tags(2,2,2);
+
+sql create stable streamt4_4(ts timestamp,a varchar(10),b tinyint,c tinyint) tags(ta int,cc int,tc int);
+
+sql create stream streams4_4 trigger at_once IGNORE EXPIRED 0 IGNORE UPDATE 0 into  streamt4_4(ts, b, a) TAGS(cc) SUBTABLE(concat(concat("tbn-", tbname), "_4")) as select _irowts, interp(a), _isfilled as a1 from st partition by tbname, b as cc every(1s) fill(NULL);
+
+run tsim/stream/checkTaskStatus.sim
+
+sql insert into t1 values(1648791217000,20000,2,3);
+
+sleep 500
+
+sql insert into t1 values(1648791212000,10000,2,3);
+
+sleep 500
+
+sql insert into t1 values(1648791215001,20,2,3);
+
+$loop_count = 0
+loop4_4:
+
+print sql select a,b from streamt4_4;
+sql select a,b from streamt4_4;
+
+if $rows != 6 then
+  print ======rows=$rows
+  goto loop4_4
+endi
+
+if $data00 != false then
+  print ======data00=$data00
+  goto loop4_4
+endi
+
+if $data01 != 16 then
+  print ======data01=$data01
+  goto loop4_4
+endi
+
+if $data10 != true then
+  print ======data10=$data10
+  goto loop4_4
+endi
+
+if $data20 != true then
+  print ======data20=$data20
+  goto loop4_4
+endi
+
+if $data50 != false then
+  print ======data50=$data50
+  goto loop4_4
+endi
+
+if $data51 != 32 then
+  print ======data51=$data51
+  goto loop4_4
+endi
+
+sql create database test4_5 vgroups 4;
+sql use test4_5;
+
+sql create stable st(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int);
+sql create table t1 using st tags(1,1,1);
+sql create table t2 using st tags(2,2,2);
+
+sql create stable streamt4_5(ts timestamp,a varchar(10),b tinyint,c tinyint) tags(ta int,cc int,tc int);
+
+sql create stream streams4_5 trigger at_once IGNORE EXPIRED 0 IGNORE UPDATE 0 into  streamt4_5(ts, b, a) TAGS(cc) SUBTABLE(concat(concat("tbn-", tbname), "_5")) as select _irowts, interp(a), _isfilled as a1 from st partition by tbname, b as cc every(1s) fill(value,1100);
+
+run tsim/stream/checkTaskStatus.sim
+
+sql insert into t1 values(1648791217000,20000,2,3);
+
+sleep 500
+
+sql insert into t1 values(1648791212000,10000,2,3);
+
+sleep 500
+
+sql insert into t1 values(1648791215001,20,2,3);
+
+$loop_count = 0
+loop4_5:
+
+print sql select a,b from streamt4_5;
+sql select a,b from streamt4_5;
+
+if $rows != 6 then
+  print ======rows=$rows
+  goto loop4_5
+endi
+
+if $data00 != false then
+  print ======data00=$data00
+  goto loop4_5
+endi
+
+if $data01 != 16 then
+  print ======data01=$data01
+  goto loop4_5
+endi
+
+if $data10 != true then
+  print ======data10=$data10
+  goto loop4_5
+endi
+
+if $data20 != true then
+  print ======data20=$data20
+  goto loop4_5
+endi
+
+if $data50 != false then
+  print ======data50=$data50
+  goto loop4_5
+endi
+
+if $data51 != 32 then
+  print ======data51=$data51
+  goto loop4_5
+endi
+system sh/exec.sh -n dnode1 -s stop -x SIGINT