Bump version to 1.9.0

lyft · Aug 29, 2022 · 9e33f46 · 9e33f46
1 parent b7b2763
commit 9e33f46
Show file tree

Hide file tree

Showing 5 changed files with 8 additions and 9 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.8.10-SNAPSHOT</version>
+        <version>1.9.0</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.8.10-SNAPSHOT</version>
+        <version>1.9.0</version>
         <relativePath>../</relativePath>
     </parent>
 

diff --git a/gateway-ha/src/main/java/com/lyft/data/gateway/ha/router/PrestoQueueLengthRoutingTable.java b/gateway-ha/src/main/java/com/lyft/data/gateway/ha/router/PrestoQueueLengthRoutingTable.java
@@ -226,8 +226,6 @@ public void updateRoutingTable(Map<String, Map<String, Integer>> updatedQueueLen
       userClusterQueueLengthMap.clear();
 
       if (updatedUserQueueLengthMap != null) {
-        log.debug("Update user queue sizes:[{}]", updatedUserQueueLengthMap.toString());
-
         for (String user : updatedUserQueueLengthMap.keySet()) {
           ConcurrentHashMap<String, Integer> clusterQueueMap =
                   new ConcurrentHashMap<>(updatedUserQueueLengthMap.get(user));
@@ -244,7 +242,8 @@ public void updateRoutingTable(Map<String, Map<String, Integer>> updatedQueueLen
         int maxQueueLen = Collections.max(updatedQueueLengthMap.get(grp).values());
         int minQueueLen = Collections.min(updatedQueueLengthMap.get(grp).values());
 
-        if (minQueueLen == maxQueueLen && updatedQueueLengthMap.get(grp).size() > 1) {
+        if (minQueueLen == maxQueueLen && updatedQueueLengthMap.get(grp).size() > 1
+                && updatedRunningLengthMap.containsKey(grp)) {
           log.info("Queue lengths equal: {} for all clusters in the group {}."
                   + " Falling back to Running Counts : {}", maxQueueLen, grp,
                   updatedRunningLengthMap.get(grp));
@@ -312,7 +311,7 @@ public String getEligibleBackEnd(String routingGroup, String user) {
         }
         // If all clusters have the same queue count, then fallback to the older weighted logic.
         if (!Strings.isNullOrEmpty(leastQueuedCluster) && minQueueCount != maxQueueCount) {
-          log.debug("Routing to:{} with userQueueCount:{}", leastQueuedCluster, minQueueCount);
+          log.debug("{} routing to:{}. userQueueCount:{}", user, leastQueuedCluster, minQueueCount);
 
           return leastQueuedCluster;
         }

diff --git a/pom.xml b/pom.xml
@@ -9,8 +9,8 @@
     <artifactId>prestogateway-parent</artifactId>
     <name>prestogateway-parent</name>
     <packaging>pom</packaging>
-    <version>1.8.10-SNAPSHOT</version>
-    
+    <version>1.9.0</version>
+
     <properties>
         <maven.compiler.source>1.8</maven.compiler.source>
         <maven.compiler.target>1.8</maven.compiler.target>

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.8.10-SNAPSHOT</version>
+        <version>1.9.0</version>
         <relativePath>../</relativePath>
     </parent>