Commit 62e34938 authored by 周昊's avatar 周昊
Browse files

1、修改日志输出

parent d375eca8

src/main/java/com/censoft/flink/StreamingJob.java

+0 −6
Original line number Diff line number Diff line
@@ -50,12 +50,6 @@ public class StreamingJob { 
        SingleOutputStreamOperator<AlgorithmPushDto> streamOperator = mqttStream

                .filter(new UpdateLiveFilterFunction(sceneId));



        //3、4 Object -> String

        streamOperator = streamOperator.map(algorithmPushDto ->{

            System.out.println(algorithmPushDto.toString());

            return algorithmPushDto;

        });



        //3、1 默认 是否存在结果集判断

        streamOperator = streamOperator

                .filter(new ResultExistFilterFunction());

src/main/java/com/censoft/flink/mqtt/MqttConsumer.java

+0 −1
Original line number Diff line number Diff line
@@ -104,7 +104,6 @@ public class MqttConsumer extends RichParallelSourceFunction<AlgorithmPushDto> { 
        public void messageArrived(String s, MqttMessage message) throws Exception {

            //订阅消息字符

            String msg = new String(message.getPayload());

            System.out.println(msg);

            byte[] bymsg = getBytesFromObject(msg);

            AlgorithmPushDto algorithmPushDto = JSON.parseObject(msg, AlgorithmPushDto.class);