Browse Source

更新

master
1049970895@qniao.cn 3 years ago
parent
commit
a0ec890f9d
1 changed files with 0 additions and 1 deletions
  1. 1
      iot-machine-state-event-generator-job/src/main/java/com/qniao/iot/machine/event/generator/job/IotMachineEventGeneratorJob.java

1
iot-machine-state-event-generator-job/src/main/java/com/qniao/iot/machine/event/generator/job/IotMachineEventGeneratorJob.java

@ -12,7 +12,6 @@ import com.qniao.iot.machine.event.MachineIotDataReceivedEventKafkaDeserializati
import com.qniao.iot.machine.event.MachineIotDataReceivedEventRabbitMqSerializationSchema;
import com.qniao.iot.machine.event.generator.config.ApolloConfig;
import com.qniao.iot.machine.event.generator.constant.ConfigConstant;
import com.qniao.iot.rc.constant.DataSource;
import com.rabbitmq.client.AMQP;
import lombok.extern.slf4j.Slf4j;
import org.apache.flink.api.common.eventtime.WatermarkStrategy;

Loading…
Cancel
Save