gaussdb

src/main/java/com/dsk/flink/dsc/sync/SyncCustomerDataSource.java

@@ -114,7 +114,7 @@ public class SyncCustomerDataSource {
                 .name("sqlResultStream")
                 .uid("sqlResultStream");
 
-        sqlResultStream1.print("async sql==>");
+        //sqlResultStream1.print("async sql==>");
 
         SingleOutputStreamOperator<String> groupWindowSqlResultStream = sqlResultStream1.keyBy(value -> value.f1)
                 .window(TumblingProcessingTimeWindows.of(Time.milliseconds(500)))
@@ -131,9 +131,6 @@ public class SyncCustomerDataSource {
                         }
                         Tuple3<String, String, Long> maxTsElement =
                                 list.stream().max(Comparator.comparing(x -> x.f2)).get();
-                        if (maxTsElement.f0.contains("甘肃华羚实业集团有限公司")) {
-                            System.out.println("=======================");
-                        }
                         out.collect(maxTsElement.f0);
                         //list.forEach(x -> {out.collect(x.f0);});
                     }