You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tz...@apache.org on 2020/09/01 10:04:45 UTC
[flink-statefun] 04/07: [hotfix] [core] Remove irrelevant
callTimeout default value
This is an automated email from the ASF dual-hosted git repository.
tzulitai pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-statefun.git
commit dcca2a5ee31247e3dbd59fba98aa5713556efd84
Author: Tzu-Li (Gordon) Tai <tz...@apache.org>
AuthorDate: Tue Sep 1 13:58:48 2020 +0800
[hotfix] [core] Remove irrelevant callTimeout default value
This default value of 2mins is actually never respected, since the
default value is solely governed by
HttpFunctionSpec#DEFAULT_HTTP_TIMEOUT (1 min).
---
.../java/org/apache/flink/statefun/flink/core/httpfn/OkHttpUtils.java | 4 ----
1 file changed, 4 deletions(-)
diff --git a/statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/OkHttpUtils.java b/statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/OkHttpUtils.java
index 71e79dd..2775667 100644
--- a/statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/OkHttpUtils.java
+++ b/statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/OkHttpUtils.java
@@ -16,7 +16,6 @@
package org.apache.flink.statefun.flink.core.httpfn;
-import java.time.Duration;
import okhttp3.ConnectionPool;
import okhttp3.Dispatcher;
import okhttp3.OkHttpClient;
@@ -24,15 +23,12 @@ import okhttp3.OkHttpClient;
final class OkHttpUtils {
private OkHttpUtils() {}
- private static final Duration DEFAULT_CALL_TIMEOUT = Duration.ofMinutes(2);
-
static OkHttpClient newClient() {
Dispatcher dispatcher = new Dispatcher();
dispatcher.setMaxRequestsPerHost(Integer.MAX_VALUE);
dispatcher.setMaxRequests(Integer.MAX_VALUE);
return new OkHttpClient.Builder()
- .callTimeout(DEFAULT_CALL_TIMEOUT)
.dispatcher(dispatcher)
.connectionPool(new ConnectionPool())
.followRedirects(true)