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(),