From eec8f9aee053beb81159b224485cde0971e07de2 Mon Sep 17 00:00:00 2001 From: "everywhere.z" Date: Fri, 12 Jul 2024 00:20:35 +0800 Subject: [PATCH] =?UTF-8?q?enhancement=20#IACEH9=20SQL=E6=8F=92=E4=BB=B6?= =?UTF-8?q?=E4=B8=AD=E7=9A=84=E8=BD=AE=E8=AF=A2=E9=80=BB=E8=BE=91=E5=8F=98?= =?UTF-8?q?=E6=9B=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../liteflow/parser/sql/util/JDBCHelper.java | 16 +--------------- 1 file changed, 1 insertion(+), 15 deletions(-) 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 b80497f3a..7dd44dc95 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 @@ -140,6 +140,7 @@ public class JDBCHelper { pollExecutor.scheduleAtFixedRate( () -> { try { + SqlReadFactory.getSqlReadPollTask(ReadType.SCRIPT).execute(); SqlReadFactory.getSqlReadPollTask(ReadType.CHAIN).execute(); } catch (Exception ex) { LOG.error("poll chain fail", ex); @@ -149,21 +150,6 @@ public class JDBCHelper { sqlParserVO.getPollingIntervalSeconds().longValue(), TimeUnit.SECONDS ); - - // 添加轮询script的定时任务 - pollExecutor.scheduleAtFixedRate( - () -> { - try { - SqlReadFactory.getSqlReadPollTask(ReadType.SCRIPT).execute(); - } catch (Exception ex) { - LOG.error("poll script fail", ex); - } - }, - sqlParserVO.getPollingStartSeconds().longValue(), - sqlParserVO.getPollingIntervalSeconds().longValue(), - TimeUnit.SECONDS - ); - } private void setSqlParserVO(SQLParserVO sqlParserVO) {