diff --git a/tests/script/tsim/stream/streamInterpNext1.sim b/tests/script/tsim/stream/streamInterpNext1.sim
index d924c82a50..9631ce8ece 100644
--- a/tests/script/tsim/stream/streamInterpNext1.sim
+++ b/tests/script/tsim/stream/streamInterpNext1.sim
@@ -244,4 +244,161 @@ if $data61 != 5 then
   goto loop4
 endi
 
+print step3
+
+sql create database test3 vgroups 1;
+sql use test3;
+
+sql create table t1(ts timestamp, a int, b int , c int, d double);
+sql create stream streams3 trigger at_once IGNORE EXPIRED 0 IGNORE UPDATE 0 into  streamt as select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 every(1s) fill(next);
+
+run tsim/stream/checkTaskStatus.sim
+
+sql insert into t1 values(1648791213001,1,1,1,1.0) (1648791219001,2,2,2,2.1) (1648791229001,3,3,3,3.1);
+
+print sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791213000, 1648791229001) every(1s) fill(next);
+sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791213000, 1648791229001) every(1s) fill(next);
+
+print $data00 $data01 $data02 $data03 $data04
+print $data10 $data11 $data12 $data13 $data14
+print $data20 $data21 $data22 $data23 $data24
+print $data30 $data31 $data32 $data33 $data34
+print $data40 $data41 $data42 $data43 $data44
+print $data50 $data51 $data52 $data53 $data54
+print $data60 $data61 $data62 $data63 $data64
+print $data70 $data71 $data72 $data73 $data74
+
+
+$loop_count = 0
+loop5:
+
+sleep 300
+
+print sql select * from streamt order by 1;
+sql select * from streamt order by 1;
+
+$loop_count = $loop_count + 1
+if $loop_count == 10 then
+  return -1
+endi
+
+if $rows != 16 then
+  print =====rows=$rows
+  goto loop5
+endi
+
+sql insert into t1 values(1648791215001,4,4,4,4.0) (1648791217001,5,5,5,5.1) (1648791222000,6,6,6,6.1) (1648791226000,7,7,7,7.1);
+
+print sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791213000, 1648791229001) every(1s) fill(next);
+sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791213000, 1648791229001) every(1s) fill(next);
+
+print $data00 $data01 $data02 $data03 $data04
+print $data10 $data11 $data12 $data13 $data14
+print $data20 $data21 $data22 $data23 $data24
+print $data30 $data31 $data32 $data33 $data34
+print $data40 $data41 $data42 $data43 $data44
+print $data50 $data51 $data52 $data53 $data54
+print $data60 $data61 $data62 $data63 $data64
+print $data70 $data71 $data72 $data73 $data74
+
+
+$loop_count = 0
+loop6:
+
+sleep 300
+
+print sql select * from streamt order by 1;
+sql select * from streamt order by 1;
+
+$loop_count = $loop_count + 1
+if $loop_count == 10 then
+  return -1
+endi
+
+if $rows != 16 then
+  goto loop6
+endi
+
+if $data01 != 4 then
+  print =====data01=$data01
+  goto loop6
+endi
+
+if $data11 != 4 then
+  print =====data11=$data11
+  goto loop6
+endi
+
+if $data21 != 5 then
+  print =====data21=$data21
+  goto loop6
+endi
+
+if $data31 != 5 then
+  print =====data31=$data31
+  goto loop6
+endi
+
+if $data41 != 2 then
+  print =====data41=$data41
+  goto loop6
+endi
+
+if $data51 != 2 then
+  print =====data51=$data51
+  goto loop6
+endi
+
+if $data61 != 6 then
+  print =====data61=$data61
+  goto loop6
+endi
+
+if $data71 != 6 then
+  print =====data71=$data71
+  goto loop6
+endi
+
+if $data81 != 6 then
+  print =====data81=$data81
+  goto loop6
+endi
+
+if $data91 != 7 then
+  print =====data91=$data91
+  goto loop6
+endi
+
+if $data[10][1] != 7 then
+  print =====data[10][1]=$data[10][1]
+  goto loop6
+endi
+
+if $data[11][1] != 7 then
+  print =====data[11][1]=$data[11][1]
+  goto loop6
+endi
+
+if $data[12][1] != 7 then
+  print =====data[12][1]=$data[12][1]
+  goto loop6
+endi
+
+if $data[13][1] != 3 then
+  print =====data[13][1]=$data[13][1]
+  goto loop6
+endi
+
+if $data[14][1] != 3 then
+  print =====data[14][1]=$data[14][1]
+  goto loop6
+endi
+
+if $data[15][1] != 3 then
+  print =====data[15][1]=$data[15][1]
+  goto loop6
+endi
+
+print end
+
 system sh/exec.sh -n dnode1 -s stop -x SIGINT
diff --git a/tests/script/tsim/stream/streamInterpPrev1.sim b/tests/script/tsim/stream/streamInterpPrev1.sim
index be8b129a4b..0beeb3e9a7 100644
--- a/tests/script/tsim/stream/streamInterpPrev1.sim
+++ b/tests/script/tsim/stream/streamInterpPrev1.sim
@@ -244,4 +244,161 @@ if $data61 != 5 then
   goto loop4
 endi
 
+print step3
+
+sql create database test3 vgroups 1;
+sql use test3;
+
+sql create table t1(ts timestamp, a int, b int , c int, d double);
+sql create stream streams3 trigger at_once IGNORE EXPIRED 0 IGNORE UPDATE 0 into  streamt as select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 every(1s) fill(prev);
+
+run tsim/stream/checkTaskStatus.sim
+
+sql insert into t1 values(1648791213001,1,1,1,1.0) (1648791219001,2,2,2,2.1) (1648791229001,3,3,3,3.1);
+
+print sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791213000, 1648791229001) every(1s) fill(prev);
+sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791213000, 1648791229001) every(1s) fill(prev);
+
+print $data00 $data01 $data02 $data03 $data04
+print $data10 $data11 $data12 $data13 $data14
+print $data20 $data21 $data22 $data23 $data24
+print $data30 $data31 $data32 $data33 $data34
+print $data40 $data41 $data42 $data43 $data44
+print $data50 $data51 $data52 $data53 $data54
+print $data60 $data61 $data62 $data63 $data64
+print $data70 $data71 $data72 $data73 $data74
+
+
+$loop_count = 0
+loop5:
+
+sleep 300
+
+print sql select * from streamt order by 1;
+sql select * from streamt order by 1;
+
+$loop_count = $loop_count + 1
+if $loop_count == 10 then
+  return -1
+endi
+
+if $rows != 16 then
+  print =====rows=$rows
+  goto loop5
+endi
+
+sql insert into t1 values(1648791215001,4,4,4,4.0) (1648791217001,5,5,5,5.1) (1648791222000,6,6,6,6.1) (1648791226000,7,7,7,7.1);
+
+print sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791213000, 1648791229001) every(1s) fill(prev);
+sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791213000, 1648791229001) every(1s) fill(prev);
+
+print $data00 $data01 $data02 $data03 $data04
+print $data10 $data11 $data12 $data13 $data14
+print $data20 $data21 $data22 $data23 $data24
+print $data30 $data31 $data32 $data33 $data34
+print $data40 $data41 $data42 $data43 $data44
+print $data50 $data51 $data52 $data53 $data54
+print $data60 $data61 $data62 $data63 $data64
+print $data70 $data71 $data72 $data73 $data74
+
+
+$loop_count = 0
+loop6:
+
+sleep 300
+
+print sql select * from streamt order by 1;
+sql select * from streamt order by 1;
+
+$loop_count = $loop_count + 1
+if $loop_count == 10 then
+  return -1
+endi
+
+if $rows != 16 then
+  goto loop6
+endi
+
+if $data01 != 1 then
+  print =====data01=$data01
+  goto loop6
+endi
+
+if $data11 != 1 then
+  print =====data11=$data11
+  goto loop6
+endi
+
+if $data21 != 4 then
+  print =====data21=$data21
+  goto loop6
+endi
+
+if $data31 != 4 then
+  print =====data31=$data31
+  goto loop6
+endi
+
+if $data41 != 5 then
+  print =====data41=$data41
+  goto loop6
+endi
+
+if $data51 != 5 then
+  print =====data51=$data51
+  goto loop6
+endi
+
+if $data61 != 2 then
+  print =====data61=$data61
+  goto loop6
+endi
+
+if $data71 != 2 then
+  print =====data71=$data71
+  goto loop6
+endi
+
+if $data81 != 6 then
+  print =====data81=$data81
+  goto loop6
+endi
+
+if $data91 != 6 then
+  print =====data91=$data91
+  goto loop6
+endi
+
+if $data[10][1] != 6 then
+  print =====data[10][1]=$data[10][1]
+  goto loop6
+endi
+
+if $data[11][1] != 6 then
+  print =====data[11][1]=$data[11][1]
+  goto loop6
+endi
+
+if $data[12][1] != 7 then
+  print =====data[12][1]=$data[12][1]
+  goto loop6
+endi
+
+if $data[13][1] != 7 then
+  print =====data[13][1]=$data[13][1]
+  goto loop6
+endi
+
+if $data[14][1] != 7 then
+  print =====data[14][1]=$data[14][1]
+  goto loop6
+endi
+
+if $data[15][1] != 7 then
+  print =====data[15][1]=$data[15][1]
+  goto loop6
+endi
+
+print end
+
 system sh/exec.sh -n dnode1 -s stop -x SIGINT