或者重试等等。
希望可以帮助到你。
Best
Aven
发件人: Yangze Guo
发送时间: 2020年5月13日 16:21
收件人: user-zh@flink.apache.org
主题: Re: 在使用flink1.7.2写入ES6的时候，有时会报错：request retries exceeded max retry timeout
[3]
您好，请问您的日志中有没有如语句
- Failed Elasticsearch bulk request:
- Failed Elasticsearch item request:
如果有，可以提供一下
从错误上看，应该
: Re: 在使用flink1.7.2写入ES6的时候，有时会报错：request retries exceeded max retry timeout
[3]
您好，请问您的日志中有没有如语句
- Failed Elasticsearch bulk request:
- Failed Elasticsearch item request:
如果有，可以提供一下
从错误上看，应该是和es交互超时了，检查一下网络连通情况，或者将timeout调大，具体方法见文档[1]
esSinkBuilder.setRestClientFactory(
restClientBuilder
hen wrote:
>
> 大家好，
>
> 我在使用flink1.7.2写入ES6的时候，有时会报错：request retries exceeded max retry timeout
> [3]，报错信息如下：
> java.lang.RuntimeException: An error occurred in ElasticsearchSink.
> at
> org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSi
大家好，
我在使用flink1.7.2写入ES6的时候，有时会报错：request retries exceeded max retry timeout
[3]，报错信息如下：
java.lang.RuntimeException: An error occurred in ElasticsearchSink.
at
org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase.checkErrorAndRethrow(ElasticsearchSinkBase.java:381)
at
