Enable Retrying max requests queued exception.
@@ -116,9 +116,16 @@ public class RequestErrorTracker
}
if (reason instanceof RejectedExecutionException) {
+ 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
if (isExpectedError(reason)) {
// don't print a stack for a known errors
