This is an automated email from the ASF dual-hosted git repository.

SbloodyS pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git


The following commit(s) were added to refs/heads/dev by this push:
     new 0e8db82a96 [Fix-18391] [Alert] Remove redundant plugin definition 
table existence check during AlertServer startup (#18392)
0e8db82a96 is described below

commit 0e8db82a96935ee5f6b1dd314356b3dd4243651e
Author: suyc <[email protected]>
AuthorDate: Mon Jul 13 15:28:37 2026 +0800

    [Fix-18391] [Alert] Remove redundant plugin definition table existence 
check during AlertServer startup (#18392)
---
 .../apache/dolphinscheduler/alert/plugin/AlertPluginManager.java | 8 --------
 .../src/main/java/org/apache/dolphinscheduler/dao/PluginDao.java | 9 ---------
 .../apache/dolphinscheduler/dao/mapper/PluginDefineMapper.java   | 7 -------
 .../apache/dolphinscheduler/dao/mapper/PluginDefineMapper.xml    | 3 ---
 4 files changed, 27 deletions(-)

diff --git 
a/dolphinscheduler-alert/dolphinscheduler-alert-server/src/main/java/org/apache/dolphinscheduler/alert/plugin/AlertPluginManager.java
 
b/dolphinscheduler-alert/dolphinscheduler-alert-server/src/main/java/org/apache/dolphinscheduler/alert/plugin/AlertPluginManager.java
index 124f654ee9..b2c310d5d5 100644
--- 
a/dolphinscheduler-alert/dolphinscheduler-alert-server/src/main/java/org/apache/dolphinscheduler/alert/plugin/AlertPluginManager.java
+++ 
b/dolphinscheduler-alert/dolphinscheduler-alert-server/src/main/java/org/apache/dolphinscheduler/alert/plugin/AlertPluginManager.java
@@ -55,7 +55,6 @@ public final class AlertPluginManager {
 
     public void start() {
         log.info("AlertPluginManager start...");
-        checkAlertPluginExist();
         installAlertPlugin();
         log.info("AlertPluginManager started...");
     }
@@ -64,13 +63,6 @@ public final class AlertPluginManager {
         return Optional.ofNullable(alertPluginMap.get(id));
     }
 
-    private void checkAlertPluginExist() {
-        if (!pluginDao.checkPluginDefineTableExist()) {
-            log.error("Plugin Define Table t_ds_plugin_define Not Exist. 
Please Create it First!");
-            System.exit(1);
-        }
-    }
-
     private void installAlertPlugin() {
         final PluginParams warningTypeParams = getWarningTypeParams();
 
diff --git 
a/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/PluginDao.java
 
b/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/PluginDao.java
index a9424c6a8e..d5d7bb7f01 100644
--- 
a/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/PluginDao.java
+++ 
b/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/PluginDao.java
@@ -38,15 +38,6 @@ public class PluginDao {
     @Autowired
     private PluginDefineMapper pluginDefineMapper;
 
-    /**
-     * check plugin define table exist
-     *
-     * @return boolean
-     */
-    public boolean checkPluginDefineTableExist() {
-        return pluginDefineMapper.checkTableExist() > 0;
-    }
-
     /**
      * add or update plugin define
      *
diff --git 
a/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/mapper/PluginDefineMapper.java
 
b/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/mapper/PluginDefineMapper.java
index 65ad0f9e5e..98085a8e78 100644
--- 
a/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/mapper/PluginDefineMapper.java
+++ 
b/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/mapper/PluginDefineMapper.java
@@ -27,13 +27,6 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 
 public interface PluginDefineMapper extends BaseMapper<PluginDefine> {
 
-    /**
-     * check table exist
-     *
-     * @return boolean
-     */
-    int checkTableExist();
-
     /**
      * query all plugin define
      *
diff --git 
a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/PluginDefineMapper.xml
 
b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/PluginDefineMapper.xml
index f61b9d1de0..707e7cf166 100644
--- 
a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/PluginDefineMapper.xml
+++ 
b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/PluginDefineMapper.xml
@@ -18,9 +18,6 @@
 
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" 
"http://mybatis.org/dtd/mybatis-3-mapper.dtd"; >
 <mapper namespace="org.apache.dolphinscheduler.dao.mapper.PluginDefineMapper">
-    <select id="checkTableExist" resultType="int">
-        select count(*) from information_schema.TABLES where table_name = 
't_ds_plugin_define'
-    </select>
 
     <select id="queryAllPluginDefineList" 
resultType="org.apache.dolphinscheduler.dao.entity.PluginDefine">
         select *

Reply via email to