diff --git a/escheduler-dao/src/main/java/cn/escheduler/dao/upgrade/EschedulerManager.java b/escheduler-dao/src/main/java/cn/escheduler/dao/upgrade/EschedulerManager.java index 0df98ec56e..15448021c3 100644 --- a/escheduler-dao/src/main/java/cn/escheduler/dao/upgrade/EschedulerManager.java +++ b/escheduler-dao/src/main/java/cn/escheduler/dao/upgrade/EschedulerManager.java @@ -66,6 +66,7 @@ public class EschedulerManager { version = "1.0.0"; }else{ logger.error("Unable to determine current software version, so cannot upgrade"); + throw new RuntimeException("Unable to determine current software version, so cannot upgrade"); } // The target version of the upgrade String schemaVersion = ""; diff --git a/escheduler-dao/src/main/java/cn/escheduler/dao/upgrade/shell/UpgradeEscheduler.java b/escheduler-dao/src/main/java/cn/escheduler/dao/upgrade/shell/UpgradeEscheduler.java index e73a1162c2..822e020cad 100644 --- a/escheduler-dao/src/main/java/cn/escheduler/dao/upgrade/shell/UpgradeEscheduler.java +++ b/escheduler-dao/src/main/java/cn/escheduler/dao/upgrade/shell/UpgradeEscheduler.java @@ -27,8 +27,6 @@ public class UpgradeEscheduler { private static final Logger logger = LoggerFactory.getLogger(UpgradeEscheduler.class); public static void main(String[] args) { - Thread.currentThread().setName("manager-UpgradeEscheduler"); - EschedulerManager eschedulerManager = new EschedulerManager(); try { eschedulerManager.upgradeEscheduler();