From 7196cf3b33e9df6b3d5a1beb74b47047149a4853 Mon Sep 17 00:00:00 2001
From: "hupenghui@qniao.cn" <1049970895>
Date: Wed, 7 Sep 2022 00:15:05 +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

---
 .../event/generator/job/IotMachineEventGeneratorJob.java     | 5 -----
 1 file changed, 5 deletions(-)

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 ecaf516..12cfe36 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
@@ -101,8 +101,6 @@ public class IotMachineEventGeneratorJob {
             "where qmrs.iot_mac = ?\n" +
             "  and qmrs.is_delete = 0";
 
-    private static final ReentrantLock lock = new ReentrantLock(true);
-
     /**
      * 当前索引日期后缀
      */
@@ -425,7 +423,6 @@ public class IotMachineEventGeneratorJob {
         GetIndexRequest exist = new GetIndexRequest(indicesName);
         // 先判断客户端是否存在
         try {
-            lock.lock();
             boolean exists = restHighLevelClient.indices().exists(exist, RequestOptions.DEFAULT);
             if (!exists) {
                 // 创建索引
@@ -500,8 +497,6 @@ public class IotMachineEventGeneratorJob {
             }
         } catch (Exception e) {
             e.printStackTrace();
-        }finally {
-            lock.unlock();
         }
     }