jinfeng created FLINK-21068:
-------------------------------
Summary: Add new timeout options for Elasticsearch connector
Key: FLINK-21068
URL:
https://issues.apache.org/jira/browse/FLINK-21068 Project: Flink
Issue Type: Improvement
Components: Connectors / ElasticSearch
Affects Versions: 1.12.1
Reporter: jinfeng
Currently, the connection.max-retry-timeout seems not work with new elasticsearch connector. The elasticsearch community has Remove setMaxRetryTimeoutMillis from RestClientBuilder. We can set timeout options when create RestHighLevelClient in
Elasticsearch7ApiCallBridge , like
{code:java}
//代码占位符
@Override
public RestHighLevelClient createClient(Map<String, String> clientConfig) throws IOException {
RestClientBuilder builder = RestClient.builder(httpHosts.toArray(new HttpHost[httpHosts.size()]));
builder.setRequestConfigCallback(new RestClientBuilder.RequestConfigCallback() {
@Override
public RequestConfig.Builder customizeRequestConfig(RequestConfig.Builder builder) {
if (clientConfig.containsKey(CONFIG_KEY_CONNECTION_TIMEOUT)) {
builder.setConnectTimeout(Integer.valueOf(clientConfig.get(CONFIG_KEY_CONNECTION_TIMEOUT)));
}
if (clientConfig.containsKey(CONFIG_KEY_CONNECTION_SOCKET_TIMEOUT)) {
builder.setSocketTimeout(Integer.valueOf(clientConfig.get(CONFIG_KEY_CONNECTION_SOCKET_TIMEOUT)));
}
if (clientConfig.containsKey(CONFIG_KEY_CONNECTION_REQUEST_TIMEOUT)) {
builder.setConnectionRequestTimeout(Integer.valueOf(clientConfig.get(CONFIG_KEY_CONNECTION_REQUEST_TIMEOUT)));
}
return builder;
}
});
{code}
So, we can add three table config to config eleasticsearch timeout.
connection.timeout
connection.socket-timeout
connection.request-timeout
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
Locked
