Xintong Song created FLINK-24095:
------------------------------------
Summary: Elasticsearch7DynamicSinkITCase.testWritingDocuments
fails due to socket timeout
Key: FLINK-24095
URL: https://issues.apache.org/jira/browse/FLINK-24095
Project: Flink
Issue Type: Bug
Components: Connectors / ElasticSearch
Affects Versions: 1.15.0
Reporter: Xintong Song
Fix For: 1.15.0
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=23250&view=logs&j=d44f43ce-542c-597d-bf94-b0718c71e5e8&t=ed165f3f-d0f6-524b-5279-86f8ee7d0e2d&l=12781
{code}
Aug 31 23:06:22 Caused by: java.net.SocketTimeoutException: 30,000 milliseconds
timeout on connection http-outgoing-3 [ACTIVE]
Aug 31 23:06:22 at
org.elasticsearch.client.RestClient.extractAndWrapCause(RestClient.java:808)
Aug 31 23:06:22 at
org.elasticsearch.client.RestClient.performRequest(RestClient.java:248)
Aug 31 23:06:22 at
org.elasticsearch.client.RestClient.performRequest(RestClient.java:235)
Aug 31 23:06:22 at
org.elasticsearch.client.RestHighLevelClient.internalPerformRequest(RestHighLevelClient.java:1514)
Aug 31 23:06:22 at
org.elasticsearch.client.RestHighLevelClient.performRequest(RestHighLevelClient.java:1499)
Aug 31 23:06:22 at
org.elasticsearch.client.RestHighLevelClient.ping(RestHighLevelClient.java:720)
Aug 31 23:06:22 at
org.apache.flink.streaming.connectors.elasticsearch7.Elasticsearch7ApiCallBridge.verifyClientConnection(Elasticsearch7ApiCallBridge.java:138)
Aug 31 23:06:22 at
org.apache.flink.streaming.connectors.elasticsearch7.Elasticsearch7ApiCallBridge.verifyClientConnection(Elasticsearch7ApiCallBridge.java:46)
Aug 31 23:06:22 at
org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase.open(ElasticsearchSinkBase.java:318)
Aug 31 23:06:22 at
org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:34)
Aug 31 23:06:22 at
org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:100)
Aug 31 23:06:22 at
org.apache.flink.streaming.api.operators.StreamSink.open(StreamSink.java:46)
Aug 31 23:06:22 at
org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.initializeStateAndOpenOperators(RegularOperatorChain.java:110)
Aug 31 23:06:22 at
org.apache.flink.streaming.runtime.tasks.StreamTask.restoreGates(StreamTask.java:691)
Aug 31 23:06:22 at
org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.call(StreamTaskActionExecutor.java:55)
Aug 31 23:06:22 at
org.apache.flink.streaming.runtime.tasks.StreamTask.restoreInternal(StreamTask.java:667)
Aug 31 23:06:22 at
org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:639)
Aug 31 23:06:22 at
org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:958)
Aug 31 23:06:22 at
org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:927)
Aug 31 23:06:22 at
org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:766)
Aug 31 23:06:22 at
org.apache.flink.runtime.taskmanager.Task.run(Task.java:575)
Aug 31 23:06:22 at java.lang.Thread.run(Thread.java:748)
Aug 31 23:06:22 Caused by: java.net.SocketTimeoutException: 30,000 milliseconds
timeout on connection http-outgoing-3 [ACTIVE]
Aug 31 23:06:22 at
org.apache.http.nio.protocol.HttpAsyncRequestExecutor.timeout(HttpAsyncRequestExecutor.java:387)
Aug 31 23:06:22 at
org.apache.http.impl.nio.client.InternalIODispatch.onTimeout(InternalIODispatch.java:92)
Aug 31 23:06:22 at
org.apache.http.impl.nio.client.InternalIODispatch.onTimeout(InternalIODispatch.java:39)
Aug 31 23:06:22 at
org.apache.http.impl.nio.reactor.AbstractIODispatch.timeout(AbstractIODispatch.java:175)
Aug 31 23:06:22 at
org.apache.http.impl.nio.reactor.BaseIOReactor.sessionTimedOut(BaseIOReactor.java:261)
Aug 31 23:06:22 at
org.apache.http.impl.nio.reactor.AbstractIOReactor.timeoutCheck(AbstractIOReactor.java:502)
Aug 31 23:06:22 at
org.apache.http.impl.nio.reactor.BaseIOReactor.validate(BaseIOReactor.java:211)
Aug 31 23:06:22 at
org.apache.http.impl.nio.reactor.AbstractIOReactor.execute(AbstractIOReactor.java:280)
Aug 31 23:06:22 at
org.apache.http.impl.nio.reactor.BaseIOReactor.execute(BaseIOReactor.java:104)
Aug 31 23:06:22 at
org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor$Worker.run(AbstractMultiworkerIOReactor.java:591)
Aug 31 23:06:22 ... 1 more
{code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
