diff --git a/dolphinscheduler-alert/src/main/java/org/apache/dolphinscheduler/alert/AlertServer.java b/dolphinscheduler-alert/src/main/java/org/apache/dolphinscheduler/alert/AlertServer.java index a41498e25842f4e21974575d6fc211c89d1d27c1..58a37c2f41dcf028617f8f9720c77df4b756a2b0 100644 --- a/dolphinscheduler-alert/src/main/java/org/apache/dolphinscheduler/alert/AlertServer.java +++ b/dolphinscheduler-alert/src/main/java/org/apache/dolphinscheduler/alert/AlertServer.java @@ -56,7 +56,7 @@ public class AlertServer { logger.info("alert server ready start "); while (Stopper.isRunning()){ try { - Thread.sleep(Constants.ALERT_SCAN_INTERVEL); + Thread.sleep(Constants.ALERT_SCAN_INTERVAL); } catch (InterruptedException e) { logger.error(e.getMessage(),e); Thread.currentThread().interrupt(); diff --git a/dolphinscheduler-alert/src/main/java/org/apache/dolphinscheduler/alert/utils/Constants.java b/dolphinscheduler-alert/src/main/java/org/apache/dolphinscheduler/alert/utils/Constants.java index f96873bdde2a0d50d74d9198f37157d76ec0d969..55c0f9ffbf601f0dd0e068d70cee49e76a03a2a2 100644 --- a/dolphinscheduler-alert/src/main/java/org/apache/dolphinscheduler/alert/utils/Constants.java +++ b/dolphinscheduler-alert/src/main/java/org/apache/dolphinscheduler/alert/utils/Constants.java @@ -133,7 +133,7 @@ public class Constants { public static final String TH_END = ""; - public static final int ALERT_SCAN_INTERVEL = 5000; + public static final int ALERT_SCAN_INTERVAL = 5000; public static final String MARKDOWN_QUOTE = ">"; diff --git a/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/thread/Stopper.java b/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/thread/Stopper.java index 1c58f879a0b05aef9aefd79e385278aa59ac0c10..cad6914cb8379c9bd03b2c9b1a6e045e147805bc 100644 --- a/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/thread/Stopper.java +++ b/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/thread/Stopper.java @@ -25,7 +25,7 @@ public class Stopper { private static volatile AtomicBoolean signal = new AtomicBoolean(false); - public static final boolean isStoped(){ + public static final boolean isStopped(){ return signal.get(); } diff --git a/dolphinscheduler-common/src/test/java/org/apache/dolphinscheduler/common/threadutils/ThreadUtilsTest.java b/dolphinscheduler-common/src/test/java/org/apache/dolphinscheduler/common/threadutils/ThreadUtilsTest.java index 52c8031e7518bd571197b0aea550837b33b1d034..2c76f40c0bd2f338db7055305443dcbc1ded4e67 100644 --- a/dolphinscheduler-common/src/test/java/org/apache/dolphinscheduler/common/threadutils/ThreadUtilsTest.java +++ b/dolphinscheduler-common/src/test/java/org/apache/dolphinscheduler/common/threadutils/ThreadUtilsTest.java @@ -98,7 +98,7 @@ public class ThreadUtilsTest { public void testStopper() { assertTrue(Stopper.isRunning()); Stopper.stop(); - assertTrue(Stopper.isStoped()); + assertTrue(Stopper.isStopped()); } /** diff --git a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/MasterServer.java b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/MasterServer.java index 2e52b834645d03a1961218b7f347e7bc8ea368a7..65c5607af73300c8a437f8f715679a80cf15a3f4 100644 --- a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/MasterServer.java +++ b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/MasterServer.java @@ -173,7 +173,7 @@ public class MasterServer implements IStoppable { try { //execute only once - if(Stopper.isStoped()){ + if(Stopper.isStopped()){ return; } diff --git a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/WorkerServer.java b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/WorkerServer.java index b3301d1825ce5c17cfc7875c375b6ad122666f2d..d270880408cfd4233549d55f6fc947b324707d88 100644 --- a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/WorkerServer.java +++ b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/WorkerServer.java @@ -201,7 +201,7 @@ public class WorkerServer implements IStoppable { try { //execute only once - if(Stopper.isStoped()){ + if(Stopper.isStopped()){ return; }