You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2020/02/14 17:31:13 UTC
[flink-statefun] 08/11: [hotfix] Include response code >= 500 as
retryable
This is an automated email from the ASF dual-hosted git repository.
sewen pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-statefun.git
commit 62a159b5d6f5d2f1777602b95c2a46885a56ab01
Author: Igal Shilman <ig...@gmail.com>
AuthorDate: Thu Feb 13 15:41:31 2020 +0100
[hotfix] Include response code >= 500 as retryable
---
.../org/apache/flink/statefun/flink/core/httpfn/RetryingCallback.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
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 f8a4a8a..567f00f 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
@@ -72,7 +72,7 @@ final class RetryingCallback implements Callback {
resultFuture.complete(response);
return;
}
- if (!RETRYABLE_HTTP_CODES.contains(response.code())) {
+ if (!RETRYABLE_HTTP_CODES.contains(response.code()) && response.code() < 500) {
throw new IllegalStateException("Non successful HTTP response code " + response.code());
}
if (!retryAfterApplyingBackoff(call)) {