From a0ec890f9d27aa787521e39f77de092db57fa40f Mon Sep 17 00:00:00 2001
From: "1049970895@qniao.cn" <1049970895>
Date: Tue, 13 Sep 2022 14:40:27 +0800
Subject: [PATCH] =?UTF-8?q?=E6=9B=B4=E6=96=B0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../machine/event/generator/job/IotMachineEventGeneratorJob.java | 1 -
 1 file changed, 1 deletion(-)

diff --git a/iot-machine-state-event-generator-job/src/main/java/com/qniao/iot/machine/event/generator/job/IotMachineEventGeneratorJob.java b/iot-machine-state-event-generator-job/src/main/java/com/qniao/iot/machine/event/generator/job/IotMachineEventGeneratorJob.java
index efa7e72..3b98522 100644
--- a/iot-machine-state-event-generator-job/src/main/java/com/qniao/iot/machine/event/generator/job/IotMachineEventGeneratorJob.java
+++ b/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;