Merge pull request #78 from lyft/cluster_alert

include cluster name in alert title
lyft · Nov 5, 2019 · 9863183 · 9863183
2 parents d8ad248 + 4b328bb
commit 9863183
Show file tree

Hide file tree

Showing 5 changed files with 11 additions and 7 deletions.
diff --git a/baseapp/pom.xml b/baseapp/pom.xml
@@ -7,7 +7,7 @@
     <parent>
         <groupId>com.lyft.data</groupId>
         <artifactId>prestogateway-parent</artifactId>
-        <version>1.6.4</version>
+        <version>1.6.5</version>
         <relativePath>../</relativePath>
     </parent>
 

diff --git a/gateway-ha/pom.xml b/gateway-ha/pom.xml
@@ -8,7 +8,7 @@
     <parent>
         <groupId>com.lyft.data</groupId>
         <artifactId>prestogateway-parent</artifactId>
-        <version>1.6.4</version>
+        <version>1.6.5</version>
         <relativePath>../</relativePath>
     </parent>
 

diff --git a/gateway-ha/src/main/java/com/lyft/data/gateway/ha/ActiveClusterMonitor.java b/gateway-ha/src/main/java/com/lyft/data/gateway/ha/ActiveClusterMonitor.java
@@ -81,15 +81,19 @@ public void start() {
   }
 
   private void notifyUnhealthyCluster(ClusterStats clusterStats) {
-    emailNotifier.sendNotification("Cluster unhealthy", clusterStats.toString());
+    emailNotifier.sendNotification(String.format("%s - Cluster unhealthy",
+            clusterStats.getClusterId()),
+            clusterStats.toString());
   }
 
   private void notifyForTooManyQueuedQueries(ClusterStats clusterStats) {
-    emailNotifier.sendNotification("Too many queued queries", clusterStats.toString());
+    emailNotifier.sendNotification(String.format("%s - Too many queued queries",
+            clusterStats.toString()), clusterStats.toString());
   }
 
   private void notifyForNoWorkers(ClusterStats clusterStats) {
-    emailNotifier.sendNotification("Number of workers", clusterStats.toString());
+    emailNotifier.sendNotification(String.format("%s - Number of workers",
+            clusterStats.getClusterId()), clusterStats.toString());
   }
 
   private ClusterStats getPrestoClusterStats(ProxyBackendConfiguration backend) {

diff --git a/pom.xml b/pom.xml
@@ -9,7 +9,7 @@
     <artifactId>prestogateway-parent</artifactId>
     <name>prestogateway-parent</name>
     <packaging>pom</packaging>
-    <version>1.6.4</version>
+    <version>1.6.5</version>
 
     <properties>
         <maven.compiler.source>1.8</maven.compiler.source>

diff --git a/proxyserver/pom.xml b/proxyserver/pom.xml
@@ -8,7 +8,7 @@
     <parent>
         <groupId>com.lyft.data</groupId>
         <artifactId>prestogateway-parent</artifactId>
-        <version>1.6.4</version>
+        <version>1.6.5</version>
         <relativePath>../</relativePath>
     </parent>