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 05:44:31 UTC
[dolphinscheduler] branch kezhenxu94-patch-1 created (now 2a341e1)
This is an automated email from the ASF dual-hosted git repository.
kezhenxu94 pushed a change to branch kezhenxu94-patch-1
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git.
at 2a341e1 Remove fast return for alert plugins
This branch includes the following new commits:
new 2a341e1 Remove fast return for alert plugins
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
[dolphinscheduler] 01/01: Remove fast return for alert plugins
Posted by ke...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
kezhenxu94 pushed a commit to branch kezhenxu94-patch-1
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git
commit 2a341e19f8d9d964ac43c15b098a30b3341793ef
Author: kezhenxu94 <ke...@apache.org>
AuthorDate: Thu Dec 30 13:44:27 2021 +0800
Remove fast return for alert plugins
---
.../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);
}