diff --git a/source/libs/executor/src/streamtimesliceoperator.c b/source/libs/executor/src/streamtimesliceoperator.c
index ee7ca4d64d..72a75b9ebf 100644
--- a/source/libs/executor/src/streamtimesliceoperator.c
+++ b/source/libs/executor/src/streamtimesliceoperator.c
@@ -1060,7 +1060,7 @@ static bool needAdjustValue(SSlicePoint* pPoint, TSKEY ts, bool isLeft, int32_t
     case TSDB_FILL_NULL_F:
     case TSDB_FILL_SET_VALUE:
     case TSDB_FILL_SET_VALUE_F: {
-      if (!isLeft && HAS_NON_ROW_DATA(pPoint->pRightRow)) {
+      if (!isLeft && (HAS_NON_ROW_DATA(pPoint->pRightRow) || pPoint->key.ts == ts) ) {
         return true;
       }
     } break;
diff --git a/tests/script/tsim/stream/streamInterpUpdate.sim b/tests/script/tsim/stream/streamInterpUpdate.sim
new file mode 100644
index 0000000000..59a188c2a6
--- /dev/null
+++ b/tests/script/tsim/stream/streamInterpUpdate.sim
@@ -0,0 +1,551 @@
+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 step1
+print =============== create database
+sql create database test vgroups 1;
+sql use test;
+
+sql create table t1(ts timestamp, a int, b int , c int, d double);
+sql create stream streams1 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(1648791212001,1,1,1,1.0) (1648791215000,10,1,1,1.0)  (1648791217001,4,1,1,1.0)
+
+print sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791212000, 1648791217001) every(1s) fill(prev);
+sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791212000, 1648791217001) 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
+
+$loop_count = 0
+
+loop0:
+
+sleep 300
+
+$loop_count = $loop_count + 1
+if $loop_count == 20 then
+  return -1
+endi
+
+print 0 sql select * from streamt;
+sql select * from streamt;
+
+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
+
+# row 0
+if $rows != 5 then
+  print ======rows=$rows
+  goto loop0
+endi
+
+# row 0
+if $data01 != 1 then
+  print ======data01=$data01
+  goto loop0
+endi
+
+if $data11 != 1 then
+  print ======data11=$data11
+  goto loop0
+endi
+
+if $data21 != 10 then
+  print ======data21=$data21
+  goto loop0
+endi
+
+if $data31 != 10 then
+  print ======data31=$data31
+  goto loop0
+endi
+
+if $data41 != 10 then
+  print ======data41=$data41
+  goto loop0
+endi
+
+sql insert into t1 values(1648791212001,2,2,2,2.1);
+
+print sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791212000, 1648791217001) every(1s) fill(prev);
+sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791212000, 1648791217001) 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
+
+$loop_count = 0
+
+loop1:
+
+sleep 300
+
+$loop_count = $loop_count + 1
+if $loop_count == 20 then
+  return -1
+endi
+
+print 0 sql select * from streamt;
+sql select * from streamt;
+
+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
+
+# row 0
+if $rows != 5 then
+  print ======rows=$rows
+  goto loop1
+endi
+
+# row 0
+if $data01 != 2 then
+  print ======data01=$data01
+  goto loop1
+endi
+
+if $data11 != 2 then
+  print ======data11=$data11
+  goto loop1
+endi
+
+if $data21 != 10 then
+  print ======data21=$data21
+  goto loop1
+endi
+
+if $data31 != 10 then
+  print ======data31=$data31
+  goto loop1
+endi
+
+if $data41 != 10 then
+  print ======data41=$data41
+  goto loop1
+endi
+
+
+sql insert into t1 values(1648791215000,20,20,20,20.1);
+
+print sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791212000, 1648791217001) every(1s) fill(prev);
+sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791212000, 1648791217001) 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
+
+$loop_count = 0
+
+loop2:
+
+sleep 300
+
+$loop_count = $loop_count + 1
+if $loop_count == 20 then
+  return -1
+endi
+
+print 0 sql select * from streamt;
+sql select * from streamt;
+
+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
+
+# row 0
+if $rows != 5 then
+  print ======rows=$rows
+  goto loop2
+endi
+
+# row 0
+if $data01 != 2 then
+  print ======data01=$data01
+  goto loop2
+endi
+
+if $data11 != 2 then
+  print ======data11=$data11
+  goto loop2
+endi
+
+if $data21 != 20 then
+  print ======data21=$data21
+  goto loop2
+endi
+
+if $data31 != 20 then
+  print ======data31=$data31
+  goto loop2
+endi
+
+if $data41 != 20 then
+  print ======data41=$data41
+  goto loop2
+endi
+
+sql insert into t1 values(1648791217001,8,8,8,8.1);
+
+print sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791212000, 1648791217001) every(1s) fill(prev);
+sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791212000, 1648791217001) 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
+
+$loop_count = 0
+
+loop3:
+
+sleep 300
+
+$loop_count = $loop_count + 1
+if $loop_count == 20 then
+  return -1
+endi
+
+print 0 sql select * from streamt;
+sql select * from streamt;
+
+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
+
+# row 0
+if $rows != 5 then
+  print ======rows=$rows
+  goto loop3
+endi
+
+# row 0
+if $data01 != 2 then
+  print ======data01=$data01
+  goto loop3
+endi
+
+if $data11 != 2 then
+  print ======data11=$data11
+  goto loop3
+endi
+
+if $data21 != 20 then
+  print ======data21=$data21
+  goto loop3
+endi
+
+if $data31 != 20 then
+  print ======data31=$data31
+  goto loop3
+endi
+
+if $data41 != 20 then
+  print ======data41=$data41
+  goto loop3
+endi
+
+print step2
+print =============== create database
+sql create database test2 vgroups 1;
+sql use test2;
+
+sql create table t1(ts timestamp, a int, b int , c int, d double);
+sql create stream streams2 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(1648791212001,1,1,1,1.0) (1648791215000,10,1,1,1.0)  (1648791217001,4,1,1,1.0)
+
+print sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791212000, 1648791217001) every(1s) fill(next);
+sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791212000, 1648791217001) 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
+
+$loop_count = 0
+
+loop4:
+
+sleep 300
+
+$loop_count = $loop_count + 1
+if $loop_count == 20 then
+  return -1
+endi
+
+print 0 sql select * from streamt;
+sql select * from streamt;
+
+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
+
+# row 0
+if $rows != 5 then
+  print ======rows=$rows
+  goto loop4
+endi
+
+# row 0
+if $data01 != 10 then
+  print ======data01=$data01
+  goto loop4
+endi
+
+if $data11 != 10 then
+  print ======data11=$data11
+  goto loop4
+endi
+
+if $data21 != 10 then
+  print ======data21=$data21
+  goto loop4
+endi
+
+if $data31 != 4 then
+  print ======data31=$data31
+  goto loop4
+endi
+
+if $data41 != 4 then
+  print ======data41=$data41
+  goto loop4
+endi
+
+sql insert into t1 values(1648791212001,2,2,2,2.1);
+
+print sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791212000, 1648791217001) every(1s) fill(next);
+sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791212000, 1648791217001) 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
+
+$loop_count = 0
+
+loop5:
+
+sleep 300
+
+$loop_count = $loop_count + 1
+if $loop_count == 20 then
+  return -1
+endi
+
+print 0 sql select * from streamt;
+sql select * from streamt;
+
+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
+
+# row 0
+if $rows != 5 then
+  print ======rows=$rows
+  goto loop5
+endi
+
+# row 0
+if $data01 != 10 then
+  print ======data01=$data01
+  goto loop5
+endi
+
+if $data11 != 10 then
+  print ======data11=$data11
+  goto loop5
+endi
+
+if $data21 != 10 then
+  print ======data21=$data21
+  goto loop5
+endi
+
+if $data31 != 4 then
+  print ======data31=$data31
+  goto loop5
+endi
+
+if $data41 != 4 then
+  print ======data41=$data41
+  goto loop5
+endi
+
+
+sql insert into t1 values(1648791215000,20,20,20,20.1);
+
+print sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791212000, 1648791217001) every(1s) fill(next);
+sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791212000, 1648791217001) 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
+
+$loop_count = 0
+
+loop6:
+
+sleep 300
+
+$loop_count = $loop_count + 1
+if $loop_count == 20 then
+  return -1
+endi
+
+print 0 sql select * from streamt;
+sql select * from streamt;
+
+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
+
+# row 0
+if $rows != 5 then
+  print ======rows=$rows
+  goto loop6
+endi
+
+# row 0
+if $data01 != 20 then
+  print ======data01=$data01
+  goto loop6
+endi
+
+if $data11 != 20 then
+  print ======data11=$data11
+  goto loop6
+endi
+
+if $data21 != 20 then
+  print ======data21=$data21
+  goto loop6
+endi
+
+if $data31 != 4 then
+  print ======data31=$data31
+  goto loop6
+endi
+
+if $data41 != 4 then
+  print ======data41=$data41
+  goto loop6
+endi
+
+sql insert into t1 values(1648791217001,8,8,8,8.1);
+
+print sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791212000, 1648791217001) every(1s) fill(next);
+sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791212000, 1648791217001) 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
+
+$loop_count = 0
+
+loop7:
+
+sleep 300
+
+$loop_count = $loop_count + 1
+if $loop_count == 20 then
+  return -1
+endi
+
+print 0 sql select * from streamt;
+sql select * from streamt;
+
+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
+
+# row 0
+if $rows != 5 then
+  print ======rows=$rows
+  goto loop7
+endi
+
+# row 0
+if $data01 != 20 then
+  print ======data01=$data01
+  goto loop7
+endi
+
+if $data11 != 20 then
+  print ======data11=$data11
+  goto loop7
+endi
+
+if $data21 != 20 then
+  print ======data21=$data21
+  goto loop7
+endi
+
+if $data31 != 8 then
+  print ======data31=$data31
+  goto loop7
+endi
+
+if $data41 != 8 then
+  print ======data41=$data41
+  goto loop7
+endi
+
+system sh/exec.sh -n dnode1 -s stop -x SIGINT
diff --git a/tests/script/tsim/stream/streamInterpUpdate1.sim b/tests/script/tsim/stream/streamInterpUpdate1.sim
new file mode 100644
index 0000000000..45f16af35d
--- /dev/null
+++ b/tests/script/tsim/stream/streamInterpUpdate1.sim
@@ -0,0 +1,551 @@
+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 step1
+print =============== create database
+sql create database test vgroups 1;
+sql use test;
+
+sql create table t1(ts timestamp, a int, b int , c int, d double);
+sql create stream streams1 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(NULL);
+
+run tsim/stream/checkTaskStatus.sim
+
+
+sql insert into t1 values(1648791212001,1,1,1,1.0) (1648791215000,10,1,1,1.0)  (1648791217001,4,1,1,1.0)
+
+print sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791212000, 1648791217001) every(1s) fill(NULL);
+sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791212000, 1648791217001) every(1s) fill(NULL);
+
+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
+
+$loop_count = 0
+
+loop0:
+
+sleep 300
+
+$loop_count = $loop_count + 1
+if $loop_count == 20 then
+  return -1
+endi
+
+print 0 sql select * from streamt;
+sql select * from streamt;
+
+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
+
+# row 0
+if $rows != 5 then
+  print ======rows=$rows
+  goto loop0
+endi
+
+# row 0
+if $data01 != NULL then
+  print ======data01=$data01
+  goto loop0
+endi
+
+if $data11 != NULL then
+  print ======data11=$data11
+  goto loop0
+endi
+
+if $data21 != 10 then
+  print ======data21=$data21
+  goto loop0
+endi
+
+if $data31 != NULL then
+  print ======data31=$data31
+  goto loop0
+endi
+
+if $data41 != NULL then
+  print ======data41=$data41
+  goto loop0
+endi
+
+sql insert into t1 values(1648791212001,2,2,2,2.1);
+
+print sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791212000, 1648791217001) every(1s) fill(NULL);
+sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791212000, 1648791217001) every(1s) fill(NULL);
+
+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
+
+$loop_count = 0
+
+loop1:
+
+sleep 300
+
+$loop_count = $loop_count + 1
+if $loop_count == 20 then
+  return -1
+endi
+
+print 0 sql select * from streamt;
+sql select * from streamt;
+
+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
+
+# row 0
+if $rows != 5 then
+  print ======rows=$rows
+  goto loop1
+endi
+
+# row 0
+if $data01 != NULL then
+  print ======data01=$data01
+  goto loop1
+endi
+
+if $data11 != NULL then
+  print ======data11=$data11
+  goto loop1
+endi
+
+if $data21 != 10 then
+  print ======data21=$data21
+  goto loop1
+endi
+
+if $data31 != NULL then
+  print ======data31=$data31
+  goto loop1
+endi
+
+if $data41 != NULL then
+  print ======data41=$data41
+  goto loop1
+endi
+
+
+sql insert into t1 values(1648791215000,20,20,20,20.1);
+
+print sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791212000, 1648791217001) every(1s) fill(NULL);
+sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791212000, 1648791217001) every(1s) fill(NULL);
+
+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
+
+$loop_count = 0
+
+loop2:
+
+sleep 300
+
+$loop_count = $loop_count + 1
+if $loop_count == 20 then
+  return -1
+endi
+
+print 0 sql select * from streamt;
+sql select * from streamt;
+
+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
+
+# row 0
+if $rows != 5 then
+  print ======rows=$rows
+  goto loop2
+endi
+
+# row 0
+if $data01 != NULL then
+  print ======data01=$data01
+  goto loop2
+endi
+
+if $data11 != NULL then
+  print ======data11=$data11
+  goto loop2
+endi
+
+if $data21 != 20 then
+  print ======data21=$data21
+  goto loop2
+endi
+
+if $data31 != NULL then
+  print ======data31=$data31
+  goto loop2
+endi
+
+if $data41 != NULL then
+  print ======data41=$data41
+  goto loop2
+endi
+
+sql insert into t1 values(1648791217001,8,8,8,8.1);
+
+print sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791212000, 1648791217001) every(1s) fill(prev);
+sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791212000, 1648791217001) 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
+
+$loop_count = 0
+
+loop3:
+
+sleep 300
+
+$loop_count = $loop_count + 1
+if $loop_count == 20 then
+  return -1
+endi
+
+print 0 sql select * from streamt;
+sql select * from streamt;
+
+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
+
+# row 0
+if $rows != 5 then
+  print ======rows=$rows
+  goto loop3
+endi
+
+# row 0
+if $data01 != NULL then
+  print ======data01=$data01
+  goto loop3
+endi
+
+if $data11 != NULL then
+  print ======data11=$data11
+  goto loop3
+endi
+
+if $data21 != 20 then
+  print ======data21=$data21
+  goto loop3
+endi
+
+if $data31 != NULL then
+  print ======data31=$data31
+  goto loop3
+endi
+
+if $data41 != NULL then
+  print ======data41=$data41
+  goto loop3
+endi
+
+print step2
+print =============== create database
+sql create database test2 vgroups 1;
+sql use test2;
+
+sql create table t1(ts timestamp, a int, b int , c int, d double);
+sql create stream streams2 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(value, 100, 200, 300, 400);
+
+run tsim/stream/checkTaskStatus.sim
+
+
+sql insert into t1 values(1648791212001,1,1,1,1.0) (1648791215000,10,1,1,1.0)  (1648791217001,4,1,1,1.0)
+
+print sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791212000, 1648791217001) every(1s) fill(value, 100, 200, 300, 400);
+sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791212000, 1648791217001) every(1s) fill(value, 100, 200, 300, 400);
+
+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
+
+$loop_count = 0
+
+loop4:
+
+sleep 300
+
+$loop_count = $loop_count + 1
+if $loop_count == 20 then
+  return -1
+endi
+
+print 0 sql select * from streamt;
+sql select * from streamt;
+
+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
+
+# row 0
+if $rows != 5 then
+  print ======rows=$rows
+  goto loop4
+endi
+
+# row 0
+if $data01 != 100 then
+  print ======data01=$data01
+  goto loop4
+endi
+
+if $data11 != 100 then
+  print ======data11=$data11
+  goto loop4
+endi
+
+if $data21 != 10 then
+  print ======data21=$data21
+  goto loop4
+endi
+
+if $data31 != 100 then
+  print ======data31=$data31
+  goto loop4
+endi
+
+if $data41 != 100 then
+  print ======data41=$data41
+  goto loop4
+endi
+
+sql insert into t1 values(1648791212001,2,2,2,2.1);
+
+print sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791212000, 1648791217001) every(1s) fill(value, 100, 200, 300, 400);
+sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791212000, 1648791217001) every(1s) fill(value, 100, 200, 300, 400);
+
+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
+
+$loop_count = 0
+
+loop5:
+
+sleep 300
+
+$loop_count = $loop_count + 1
+if $loop_count == 20 then
+  return -1
+endi
+
+print 0 sql select * from streamt;
+sql select * from streamt;
+
+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
+
+# row 0
+if $rows != 5 then
+  print ======rows=$rows
+  goto loop5
+endi
+
+# row 0
+if $data01 != 100 then
+  print ======data01=$data01
+  goto loop5
+endi
+
+if $data11 != 100 then
+  print ======data11=$data11
+  goto loop5
+endi
+
+if $data21 != 10 then
+  print ======data21=$data21
+  goto loop5
+endi
+
+if $data31 != 100 then
+  print ======data31=$data31
+  goto loop5
+endi
+
+if $data41 != 100 then
+  print ======data41=$data41
+  goto loop5
+endi
+
+
+sql insert into t1 values(1648791215000,20,20,20,20.1);
+
+print sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791212000, 1648791217001) every(1s) fill(value, 100, 200, 300, 400);
+sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791212000, 1648791217001) every(1s) fill(value, 100, 200, 300, 400);
+
+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
+
+$loop_count = 0
+
+loop6:
+
+sleep 300
+
+$loop_count = $loop_count + 1
+if $loop_count == 20 then
+  return -1
+endi
+
+print 0 sql select * from streamt;
+sql select * from streamt;
+
+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
+
+# row 0
+if $rows != 5 then
+  print ======rows=$rows
+  goto loop6
+endi
+
+# row 0
+if $data01 != 100 then
+  print ======data01=$data01
+  goto loop6
+endi
+
+if $data11 != 100 then
+  print ======data11=$data11
+  goto loop6
+endi
+
+if $data21 != 20 then
+  print ======data21=$data21
+  goto loop6
+endi
+
+if $data31 != 100 then
+  print ======data31=$data31
+  goto loop6
+endi
+
+if $data41 != 100 then
+  print ======data41=$data41
+  goto loop6
+endi
+
+sql insert into t1 values(1648791217001,8,8,8,8.1);
+
+print sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791212000, 1648791217001) every(1s) fill(value, 100, 200, 300, 400);
+sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791212000, 1648791217001) every(1s) fill(value, 100, 200, 300, 400);
+
+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
+
+$loop_count = 0
+
+loop7:
+
+sleep 300
+
+$loop_count = $loop_count + 1
+if $loop_count == 20 then
+  return -1
+endi
+
+print 0 sql select * from streamt;
+sql select * from streamt;
+
+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
+
+# row 0
+if $rows != 5 then
+  print ======rows=$rows
+  goto loop7
+endi
+
+# row 0
+if $data01 != 100 then
+  print ======data01=$data01
+  goto loop7
+endi
+
+if $data11 != 100 then
+  print ======data11=$data11
+  goto loop7
+endi
+
+if $data21 != 20 then
+  print ======data21=$data21
+  goto loop7
+endi
+
+if $data31 != 100 then
+  print ======data31=$data31
+  goto loop7
+endi
+
+if $data41 != 100 then
+  print ======data41=$data41
+  goto loop7
+endi
+
+system sh/exec.sh -n dnode1 -s stop -x SIGINT
diff --git a/tests/script/tsim/stream/streamInterpUpdate2.sim b/tests/script/tsim/stream/streamInterpUpdate2.sim
new file mode 100644
index 0000000000..2a71474dd7
--- /dev/null
+++ b/tests/script/tsim/stream/streamInterpUpdate2.sim
@@ -0,0 +1,279 @@
+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 step1
+print =============== create database
+sql create database test vgroups 1;
+sql use test;
+
+sql create table t1(ts timestamp, a int, b int , c int, d double);
+sql create stream streams1 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(linear);
+
+run tsim/stream/checkTaskStatus.sim
+
+
+sql insert into t1 values(1648791212001,1,1,1,1.0) (1648791215000,10,1,1,1.0)  (1648791217001,4,1,1,1.0)
+
+print sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791212000, 1648791217001) every(1s) fill(linear);
+sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791212000, 1648791217001) every(1s) fill(linear);
+
+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
+
+$loop_count = 0
+
+loop0:
+
+sleep 300
+
+$loop_count = $loop_count + 1
+if $loop_count == 20 then
+  return -1
+endi
+
+print 0 sql select * from streamt;
+sql select * from streamt;
+
+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
+
+# row 0
+if $rows != 5 then
+  print ======rows=$rows
+  goto loop0
+endi
+
+# row 0
+if $data01 != 3 then
+  print ======data01=$data01
+  goto loop0
+endi
+
+if $data11 != 6 then
+  print ======data11=$data11
+  goto loop0
+endi
+
+if $data21 != 10 then
+  print ======data21=$data21
+  goto loop0
+endi
+
+if $data31 != 7 then
+  print ======data31=$data31
+  goto loop0
+endi
+
+if $data41 != 4 then
+  print ======data41=$data41
+  goto loop0
+endi
+
+sql insert into t1 values(1648791212001,2,2,2,2.1);
+
+print sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791212000, 1648791217001) every(1s) fill(linear);
+sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791212000, 1648791217001) every(1s) fill(linear);
+
+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
+
+$loop_count = 0
+
+loop1:
+
+sleep 300
+
+$loop_count = $loop_count + 1
+if $loop_count == 20 then
+  return -1
+endi
+
+print 0 sql select * from streamt;
+sql select * from streamt;
+
+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
+
+# row 0
+if $rows != 5 then
+  print ======rows=$rows
+  goto loop1
+endi
+
+# row 0
+if $data01 != 4 then
+  print ======data01=$data01
+  goto loop1
+endi
+
+if $data11 != 7 then
+  print ======data11=$data11
+  goto loop1
+endi
+
+if $data21 != 10 then
+  print ======data21=$data21
+  goto loop1
+endi
+
+if $data31 != 7 then
+  print ======data31=$data31
+  goto loop1
+endi
+
+if $data41 != 4 then
+  print ======data41=$data41
+  goto loop1
+endi
+
+
+sql insert into t1 values(1648791215000,20,20,20,20.1);
+
+print sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791212000, 1648791217001) every(1s) fill(linear);
+sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791212000, 1648791217001) every(1s) fill(linear);
+
+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
+
+$loop_count = 0
+
+loop2:
+
+sleep 300
+
+$loop_count = $loop_count + 1
+if $loop_count == 20 then
+  return -1
+endi
+
+print 0 sql select * from streamt;
+sql select * from streamt;
+
+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
+
+# row 0
+if $rows != 5 then
+  print ======rows=$rows
+  goto loop2
+endi
+
+# row 0
+if $data01 != 7 then
+  print ======data01=$data01
+  goto loop2
+endi
+
+if $data11 != 13 then
+  print ======data11=$data11
+  goto loop2
+endi
+
+if $data21 != 20 then
+  print ======data21=$data21
+  goto loop2
+endi
+
+if $data31 != 12 then
+  print ======data31=$data31
+  goto loop2
+endi
+
+if $data41 != 4 then
+  print ======data41=$data41
+  goto loop2
+endi
+
+sql insert into t1 values(1648791217001,8,8,8,8.1);
+
+print sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791212000, 1648791217001) every(1s) fill(linear);
+sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791212000, 1648791217001) every(1s) fill(linear);
+
+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
+
+$loop_count = 0
+
+loop3:
+
+sleep 300
+
+$loop_count = $loop_count + 1
+if $loop_count == 20 then
+  return -1
+endi
+
+print 0 sql select * from streamt;
+sql select * from streamt;
+
+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
+
+# row 0
+if $rows != 5 then
+  print ======rows=$rows
+  goto loop3
+endi
+
+# row 0
+if $data01 != 7 then
+  print ======data01=$data01
+  goto loop3
+endi
+
+if $data11 != 13 then
+  print ======data11=$data11
+  goto loop3
+endi
+
+if $data21 != 20 then
+  print ======data21=$data21
+  goto loop3
+endi
+
+if $data31 != 14 then
+  print ======data31=$data31
+  goto loop3
+endi
+
+if $data41 != 8 then
+  print ======data41=$data41
+  goto loop3
+endi
+
+system sh/exec.sh -n dnode1 -s stop -x SIGINT