1、添加对于数据库无摄像头数据报错校验

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("192.168.10.137:9092", "test-topic", new SimpleStringSchema()));