From 5f3efee72e9aa79bce173271c86df4df314a467e Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Fr=C3=A9d=C3=A9rique=20Mittelstaedt?= Date: Thu, 31 Aug 2023 12:07:37 +0100 Subject: [PATCH 1/2] More retryable http status codes --- .../flink/statefun/flink/core/httpfn/RetryingCallback.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/RetryingCallback.java b/statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/RetryingCallback.java index ffb7f7bb7..1b0c2e190 100644 --- a/statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/RetryingCallback.java +++ b/statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/RetryingCallback.java @@ -42,8 +42,8 @@ final class RetryingCallback implements Callback { private static final Duration INITIAL_BACKOFF_DURATION = Duration.ofMillis(10); - private static final Set RETRYABLE_HTTP_CODES = - new HashSet<>(Arrays.asList(409, 420, 408, 429, 499, 500)); + private static final Set RETRYABLE_HTTP_CODES = new HashSet<>( + Arrays.asList(400, 408, 409, 420, 429, 499, 500, 503, 504)); private static final Logger LOG = LoggerFactory.getLogger(RetryingCallback.class); From 5d29bcbfafaf85d8336e6f28a1cef4f113ca12c9 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Fr=C3=A9d=C3=A9rique=20Mittelstaedt?= Date: Thu, 31 Aug 2023 11:55:30 +0000 Subject: [PATCH 2/2] mvn spotless:apply --- .../flink/statefun/flink/core/httpfn/RetryingCallback.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/RetryingCallback.java b/statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/RetryingCallback.java index 1b0c2e190..2f0289254 100644 --- a/statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/RetryingCallback.java +++ b/statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/RetryingCallback.java @@ -42,8 +42,8 @@ final class RetryingCallback implements Callback { private static final Duration INITIAL_BACKOFF_DURATION = Duration.ofMillis(10); - private static final Set RETRYABLE_HTTP_CODES = new HashSet<>( - Arrays.asList(400, 408, 409, 420, 429, 499, 500, 503, 504)); + private static final Set RETRYABLE_HTTP_CODES = + new HashSet<>(Arrays.asList(400, 408, 409, 420, 429, 499, 500, 503, 504)); private static final Logger LOG = LoggerFactory.getLogger(RetryingCallback.class);