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 f2e96a0..7d08e57 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
@@ -49,13 +49,17 @@ import java.util.stream.Collectors;
 
 public class IotMachineEventGeneratorJob {
 
-    private final static String SQL = "select qm.id as machine_id, qei.mac as machine_iot_mac, qm.status\n" +
+    /*private final static String SQL = "select qm.id as machine_id, qei.mac as machine_iot_mac, qm.status\n" +
             "from (select id, status from qn_machine where is_delete = 0) qm\n" +
             "         left join (select machine_id, equipment_information_id\n" +
             "                    from qn_machine_binding_cloud_box\n" +
             "                    where is_delete = 0) qmbcb ON qm.id = qmbcb.machine_id\n" +
             "         left join (select id, mac from qn_equipment_information where is_delete = 0) qei\n" +
-            "                   on qei.id = qmbcb.equipment_information_id";
+            "                   on qei.id = qmbcb.equipment_information_id";*/
+
+    private final static String SQL = "select machine_id, iot_mac as machine_iot_mac, status\n" +
+            "from qn_machine_realtime_state\n" +
+            "where is_delete = 0";
 
     public static void main(String[] args) throws Exception {