From fde9eeb9ca06ef2c6ff5e89786118437ed3f1ade Mon Sep 17 00:00:00 2001
From: 54liuyao <54liuyao@163.com>
Date: Thu, 31 Oct 2024 16:10:05 +0800
Subject: [PATCH] fix ci issue

---
 source/libs/executor/src/streamtimesliceoperator.c        | 4 ++--
 tests/system-test/8-stream/force_window_close_interval.py | 4 ++--
 2 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/source/libs/executor/src/streamtimesliceoperator.c b/source/libs/executor/src/streamtimesliceoperator.c
index 113d5d5f5a..b49b42f0b2 100644
--- a/source/libs/executor/src/streamtimesliceoperator.c
+++ b/source/libs/executor/src/streamtimesliceoperator.c
@@ -1840,13 +1840,13 @@ static int32_t doStreamTimeSliceNext(SOperatorInfo* pOperator, SSDataBlock** ppR
   if (taosArrayGetSize(pInfo->pCloseTs) > 0) {
     removeDuplicateTs(pInfo->pCloseTs);
     int32_t size = taosArrayGetSize(pInfo->pCloseTs);
-    qDebug("build stream result, ts count:%d", size);
+    qDebug("===stream===build stream result, ts count:%d", size);
     for (int32_t i = 0; i < size; i++) {
       TSKEY ts = *(TSKEY*) taosArrayGet(pInfo->pCloseTs, i);
       code = buildAllResultKey(&pInfo->streamAggSup, ts, pInfo->pUpdated);
       QUERY_CHECK_CODE(code, lino, _end);
     }
-    qDebug("build stream result, ts count:%d", taosArrayGetSize(pInfo->pUpdated));
+    qDebug("===stream===build stream result, res count:%ld", taosArrayGetSize(pInfo->pUpdated));
     taosArrayClear(pInfo->pCloseTs);
     if (size > 1024) {
       taosArrayDestroy(pInfo->pCloseTs);
diff --git a/tests/system-test/8-stream/force_window_close_interval.py b/tests/system-test/8-stream/force_window_close_interval.py
index d0e87847a9..34e03dbc70 100644
--- a/tests/system-test/8-stream/force_window_close_interval.py
+++ b/tests/system-test/8-stream/force_window_close_interval.py
@@ -533,12 +533,12 @@ class TDTestCase:
                         )
                         self.tdCom.check_query_data(
                             f'select irowts, table_name, c_c1, isfilled, {funciton_name_alias} from {self.stb_stream_des_partition_column1_table} where irowts >= {start_force_ts}   and irowts <= "{end_new_ts}"  order by c_c1, irowts',
-                            f'select _irowts as irowts ,tbname as table_name, c1 as c_c1, _isfilled as isfilled , {funciton_name} as  {funciton_name_alias}  from {tbname} {where_tbname}  partition by {partition},c1  range("{start_new_ts}","{end_new_ts}")  every({self.tdCom.dataDict["interval"]}s) fill ({fill_value}) order by c_c1, irowts',
+                            f'select _irowts as irowts ,tbname as table_name, c1 as c_c1, _isfilled as isfilled , {funciton_name} as  {funciton_name_alias}  from {tbname} {where_tbname} and ts >=  {start_force_ts} partition by {partition},c1  range("{start_new_ts}","{end_new_ts}")  every({self.tdCom.dataDict["interval"]}s) fill ({fill_value}) order by c_c1, irowts',
                             fill_value=fill_value,
                         )    
                         self.tdCom.check_query_data(
                             f'select irowts, table_name, c_c2, isfilled, {funciton_name_alias} from {self.stb_stream_des_partition_column2_table} where irowts >= {start_force_ts}   and irowts <= "{end_new_ts}"  order by c_c2, irowts',
-                            f'select _irowts as irowts ,tbname as table_name, c2 as c_c2, _isfilled as isfilled , {funciton_name} as  {funciton_name_alias}  from {tbname},  {where_tbname}  partition by {partition},c2  range("{start_new_ts}","{end_new_ts}")  every({self.tdCom.dataDict["interval"]}s) fill ({fill_value}) order by c_c2, irowts',
+                            f'select _irowts as irowts ,tbname as table_name, c2 as c_c2, _isfilled as isfilled , {funciton_name} as  {funciton_name_alias}  from {tbname} {where_tbname} and ts >=  {start_force_ts} partition by {partition},c2  range("{start_new_ts}","{end_new_ts}")  every({self.tdCom.dataDict["interval"]}s) fill ({fill_value}) order by c_c2, irowts',
                             fill_value=fill_value,
                         )                        
                 else: