Enable Retrying max requests queued exception.

prestodb · Mar 15, 2022 · 3913a1a · 3913a1a
1 parent 8479f26
commit 3913a1a
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/presto-main/src/main/java/com/facebook/presto/server/RequestErrorTracker.java b/presto-main/src/main/java/com/facebook/presto/server/RequestErrorTracker.java
@@ -116,7 +116,14 @@ public void requestFailed(Throwable reason)
         }
 
         if (reason instanceof RejectedExecutionException) {
-            throw new PrestoException(errorCode, reason);
+            if (reason.getMessage() == null) {
+                throw new PrestoException(errorCode, reason);
+            }
+
+            // We want to do exponential backoff to allow OOT killer to kill queries and not fail immediately.
+            if (!reason.getMessage().contains("Max requests queued per destination")) {
+                throw new PrestoException(errorCode, reason);
+            }
         }
 
         // log failure message