Merge branch 'master' into production

dfb03a81 · 周昊 · 9e3c0da9 · ed92ab30 · dfb03a81
Commit dfb03a81 authored Nov 08, 2023 by 周昊
Hide whitespace changes
Inline Side-by-side

Showing with 1 addition and 1 deletion

src/main/java/com/censoft/flink/StreamingJob.java src/main/java/com/censoft/flink/StreamingJob.java +1 -1

No files found.
--- a/src/main/java/com/censoft/flink/StreamingJob.java
+++ b/src/main/java/com/censoft/flink/StreamingJob.java
@@ -107,7 +107,7 @@ public class StreamingJob {
        });

        //去空
-        outputStreamOperator = outputStreamOperator.filter(algorithmPushString -> algorithmPushString!= null && "".equals(algorithmPushString));
+        outputStreamOperator = outputStreamOperator.filter(algorithmPushString -> algorithmPushString!= null && !"".equals(algorithmPushString));

        //3、5 输出kafka
        outputStreamOperator.addSink(new FlinkKafkaProducer("172.16.20.211:9092", "test-topic", new SimpleStringSchema()));