[ https://issues.apache.org/jira/browse/FLINK-24095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17703027#comment-17703027 ]
Leonard Xu commented on FLINK-24095: ------------------------------------ {noformat} Mar 14 01:50:08 [ERROR] Elasticsearch7DynamicSinkITCase.testWritingDocumentsWithDynamicIndexFromSystemTime:41->ElasticsearchDynamicSinkBaseITCase.testWritingDocumentsWithDynamicIndexFromSystemTime:338 » Execution Mar 14 01:48:43 Caused by: java.lang.RuntimeException: An error occurred in ElasticsearchSink. Mar 14 01:48:43 at org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase.checkErrorAndRethrow(ElasticsearchSinkBase.java:426) Mar 14 01:48:43 at org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase.close(ElasticsearchSinkBase.java:365) Mar 14 01:48:43 at org.apache.flink.api.common.functions.util.FunctionUtils.closeFunction(FunctionUtils.java:41) Mar 14 01:48:43 at org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.close(AbstractUdfStreamOperator.java:114) Mar 14 01:48:43 at org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.close(StreamOperatorWrapper.java:163) Mar 14 01:48:43 at org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.closeAllOperators(RegularOperatorChain.java:125) Mar 14 01:48:43 at org.apache.flink.streaming.runtime.tasks.StreamTask.closeAllOperators(StreamTask.java:1000) Mar 14 01:48:43 at org.apache.flink.streaming.runtime.tasks.StreamTask.afterInvoke(StreamTask.java:879) Mar 14 01:48:43 at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:762) Mar 14 01:48:43 at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:948) Mar 14 01:48:43 at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:927) Mar 14 01:48:43 at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:741) Mar 14 01:48:43 at org.apache.flink.runtime.taskmanager.Task.run(Task.java:563) Mar 14 01:48:43 at java.lang.Thread.run(Thread.java:748) Mar 14 01:48:43 Caused by: java.net.SocketTimeoutException: 30,000 milliseconds timeout on connection http-outgoing-2 [ACTIVE] Mar 14 01:48:43 at org.apache.http.nio.protocol.HttpAsyncRequestExecutor.timeout(HttpAsyncRequestExecutor.java:387) Mar 14 01:48:43 at org.apache.http.impl.nio.client.InternalIODispatch.onTimeout(InternalIODispatch.java:92) Mar 14 01:48:43 at org.apache.http.impl.nio.client.InternalIODispatch.onTimeout(InternalIODispatch.java:39) Mar 14 01:48:43 at org.apache.http.impl.nio.reactor.AbstractIODispatch.timeout(AbstractIODispatch.java:175) Mar 14 01:48:43 at org.apache.http.impl.nio.reactor.BaseIOReactor.sessionTimedOut(BaseIOReactor.java:261) Mar 14 01:48:43 at org.apache.http.impl.nio.reactor.AbstractIOReactor.timeoutCheck(AbstractIOReactor.java:502) Mar 14 01:48:43 at org.apache.http.impl.nio.reactor.BaseIOReactor.validate(BaseIOReactor.java:211) Mar 14 01:48:43 at org.apache.http.impl.nio.reactor.AbstractIOReactor.execute(AbstractIOReactor.java:280) Mar 14 01:48:43 at org.apache.http.impl.nio.reactor.BaseIOReactor.execute(BaseIOReactor.java:104) Mar 14 01:48:43 at org.apache.http.impl {noformat} I guess it is same issue in release-1.15: https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=47128&view=logs&j=ba53eb01-1462-56a3-8e98-0dd97fbcaab5&t=2e426bf0-b717-56bb-ab62-d63086457354 > 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.14.0, 1.15.0, 1.16.0, elasticsearch-3.0.0 > Reporter: Xintong Song > Priority: Major > Labels: test-stability > Fix For: elasticsearch-4.0.0, elasticsearch-3.0.1 > > > 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.20.10#820010)