From 94d458f62828e4e99d815fd16b11217890c665c8 Mon Sep 17 00:00:00 2001
From: gaibu <1016771049@qq.com>
Date: Fri, 29 Sep 2023 21:34:07 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E6=97=A5=E5=BF=97=E7=BA=A7?=
 =?UTF-8?q?=E5=88=AB?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../liteflow/parser/sql/polling/AbstractSqlReadPollTask.java  | 2 +-
 .../java/com/yomahub/liteflow/parser/sql/util/JDBCHelper.java | 4 ++--
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/liteflow-rule-plugin/liteflow-rule-sql/src/main/java/com/yomahub/liteflow/parser/sql/polling/AbstractSqlReadPollTask.java b/liteflow-rule-plugin/liteflow-rule-sql/src/main/java/com/yomahub/liteflow/parser/sql/polling/AbstractSqlReadPollTask.java
index a2c951925..2f3873865 100644
--- a/liteflow-rule-plugin/liteflow-rule-sql/src/main/java/com/yomahub/liteflow/parser/sql/polling/AbstractSqlReadPollTask.java
+++ b/liteflow-rule-plugin/liteflow-rule-sql/src/main/java/com/yomahub/liteflow/parser/sql/polling/AbstractSqlReadPollTask.java
@@ -36,7 +36,7 @@ public abstract class AbstractSqlReadPollTask implements SqlReadPollTask {
     public void execute() {
         Map<String/*唯一键*/, String/*data-xml*/> newData = read.read();
         // 新增或者更新的元素
-        Map<String, String> saveElementMap = new HashMap();
+        Map<String, String> saveElementMap = new HashMap<>();
         // 删除的元素
         List<String> deleteElementIds = new ArrayList<>();
 
diff --git a/liteflow-rule-plugin/liteflow-rule-sql/src/main/java/com/yomahub/liteflow/parser/sql/util/JDBCHelper.java b/liteflow-rule-plugin/liteflow-rule-sql/src/main/java/com/yomahub/liteflow/parser/sql/util/JDBCHelper.java
index a181ccd79..0c3c4db2d 100644
--- a/liteflow-rule-plugin/liteflow-rule-sql/src/main/java/com/yomahub/liteflow/parser/sql/util/JDBCHelper.java
+++ b/liteflow-rule-plugin/liteflow-rule-sql/src/main/java/com/yomahub/liteflow/parser/sql/util/JDBCHelper.java
@@ -126,7 +126,7 @@ public class JDBCHelper {
                     try {
                         SqlReadFactory.getSqlReadPollTask(ReadType.CHAIN).execute();
                     } catch (Exception ex) {
-                        LOG.info("poll chain fail", ex);
+                        LOG.error("poll chain fail", ex);
                     }
                 },
                 sqlParserVO.getPollingStartSeconds().longValue(),
@@ -140,7 +140,7 @@ public class JDBCHelper {
                     try {
                         SqlReadFactory.getSqlReadPollTask(ReadType.SCRIPT).execute();
                     } catch (Exception ex) {
-                        LOG.info("poll script fail", ex);
+                        LOG.error("poll script fail", ex);
                     }
                 },
                 sqlParserVO.getPollingStartSeconds().longValue(),