| commit | e9a20a765bec5418ac2e8870e9541505013ced9c | [log] [tgz] |
|---|---|---|
| author | Igal Shilman <igalshilman@gmail.com> | Sun Sep 20 22:18:30 2020 +0200 |
| committer | Tzu-Li (Gordon) Tai <tzulitai@apache.org> | Mon Sep 21 13:12:32 2020 +0800 |
| tree | 67670f1c372c8771ac04805c742883b637e14b31 | |
| parent | 769b5c7f55d4b906fb9e518f3e60cf7788807213 [diff] |
[FLINK-19296][http] Do not retry HTTP calls on shutdown This closes #156.
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 98184d5..ffb7f7b 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
@@ -87,6 +87,9 @@ } private void onFailureUnsafe(Call call, IOException cause) { + if (isShutdown.getAsBoolean()) { + throw new IllegalStateException("An exception caught during shutdown.", cause); + } LOG.warn( "Retriable exception caught while trying to deliver a message: " + requestSummary, cause); metrics.remoteInvocationFailures();