[hotfix-32959][core][launcher]fix group by window no retract

Author: simenliuxing

core/src/main/java/com/dtstack/flink/sql/side/SideSqlExec.java

@@ -525,6 +525,7 @@ private void joinFun(Object pollObj,
         RowTypeInfo typeInfo = new RowTypeInfo(fieldDataTypes, targetTable.getSchema().getFieldNames());
 
         DataStream<BaseRow> adaptStream = tableEnv.toRetractStream(targetTable, typeInfo)
+                .filter(f -> f.f0)
                 .map(f -> RowDataConvert.convertToBaseRow(f));
 
         //join side table before keyby ===> Reducing the size of each dimension table cache of async

launcher/src/main/java/org/apache/flink/table/planner/plan/QueryOperationConverter.java

@@ -442,7 +442,7 @@ private RelNode convertToDataStreamScan(
                     rowType,
                     dataStream,
                     false,
-                    true,
+                    false,
                     fieldIndices,
                     tableSchema.getFieldNames(),
                     FlinkStatistic.UNKNOWN(),