From 68f736953b1f0fc0ee5221bf6da2891b4abe8ab0 Mon Sep 17 00:00:00 2001 From: ZHAOLIPAN <1185807945@qq.com> Date: Tue, 14 Jan 2020 16:15:34 +0800 Subject: [PATCH] fix typos (#1821) --- .../java/org/apache/dolphinscheduler/alert/AlertServer.java | 2 +- .../java/org/apache/dolphinscheduler/alert/utils/Constants.java | 2 +- .../java/org/apache/dolphinscheduler/common/thread/Stopper.java | 2 +- .../dolphinscheduler/common/threadutils/ThreadUtilsTest.java | 2 +- .../org/apache/dolphinscheduler/server/master/MasterServer.java | 2 +- .../org/apache/dolphinscheduler/server/worker/WorkerServer.java | 2 +- 6 files changed, 6 insertions(+), 6 deletions(-) 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 a41498e258..58a37c2f41 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 f96873bdde..55c0f9ffbf 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 1c58f879a0..cad6914cb8 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 52c8031e75..2c76f40c0b 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 2e52b83464..65c5607af7 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 b3301d1825..d270880408 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; }