You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dolphinscheduler.apache.org by ke...@apache.org on 2021/12/30 07:02:08 UTC
[dolphinscheduler] branch dev updated: Remove fast return for alert plugins (#7723)
This is an automated email from the ASF dual-hosted git repository.
kezhenxu94 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 68906f1 Remove fast return for alert plugins (#7723)
68906f1 is described below
commit 68906f1b31d60e38414de6a82feff5232e4a00b4
Author: kezhenxu94 <ke...@apache.org>
AuthorDate: Thu Dec 30 15:02:03 2021 +0800
Remove fast return for alert plugins (#7723)
---
.../src/main/java/org/apache/dolphinscheduler/alert/AlertServer.java | 5 -----
1 file changed, 5 deletions(-)
diff --git a/dolphinscheduler-alert/dolphinscheduler-alert-server/src/main/java/org/apache/dolphinscheduler/alert/AlertServer.java b/dolphinscheduler-alert/dolphinscheduler-alert-server/src/main/java/org/apache/dolphinscheduler/alert/AlertServer.java
index 1d2ffb1..6304a4c 100644
--- a/dolphinscheduler-alert/dolphinscheduler-alert-server/src/main/java/org/apache/dolphinscheduler/alert/AlertServer.java
+++ b/dolphinscheduler-alert/dolphinscheduler-alert-server/src/main/java/org/apache/dolphinscheduler/alert/AlertServer.java
@@ -75,11 +75,6 @@ public class AlertServer implements Closeable {
checkTable();
startServer();
- if (alertPluginManager.size() == 0) {
- logger.warn("No alert plugin, alert sender will exit.");
- return;
- }
-
Executors.newScheduledThreadPool(1)
.scheduleAtFixedRate(new Sender(), 5, 5, TimeUnit.SECONDS);
}