更新

3 years ago · d08e281991
1 changed files with 1 additions and 1 deletions
--- a/src/main/java/com/qniao/iot/IotMonitoringDataJob.java
+++ b/src/main/java/com/qniao/iot/IotMonitoringDataJob.java
@ -100,7 +100,7 @@ public class IotMonitoringDataJob {

        final DataStream<MachineOutputCommand> stream = env
                .addSource(new RMQSource<>(connectionConfig, ApolloConfig.getStr(ConfigConstant.SOURCE_RABBITMQ_QUEUE),
-                        true, new MachineOutputCommandDeserializationSchema())).setParallelism(1);
+                        false, new MachineOutputCommandDeserializationSchema())).setParallelism(1);

        // mac分组并进行工作时长的集合操作
        DataStream<DeviceMonitoringData> machineIotDataReceivedEventDataStream = stream