diff --git a/tests/system-test/8-stream/window_close_session.py b/tests/system-test/8-stream/window_close_session.py
index 0a523a056f..f9f6baab75 100644
--- a/tests/system-test/8-stream/window_close_session.py
+++ b/tests/system-test/8-stream/window_close_session.py
@@ -47,10 +47,7 @@ class TDTestCase:
                     self.tdCom.sinsert_rows(tbname=self.tb_name, ts_value=ts_value)
                     if i == 0 and fill_history_value is not None:
                         for tbname in [self.ctb_stream_des_table, self.tb_stream_des_table]:
-                            if tbname != self.tb_stream_des_table:
-                                tdSql.query(f'select count(*) from {tbname}', count_expected_res=1)
-                            else:
-                                tdSql.query(f'select count(*) from {tbname}', count_expected_res=1)
+                            tdSql.query(f'select count(*) from {tbname}', count_expected_res=1)
                     if self.tdCom.update and i%2 == 0:
                         self.tdCom.sinsert_rows(tbname=self.ctb_name, ts_value=ts_value)
                         self.tdCom.sinsert_rows(tbname=self.tb_name, ts_value=ts_value)