[
https://issues.apache.org/jira/browse/FLINK-28877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huang Xingbo closed FLINK-28877.
--------------------------------
Resolution: Duplicate
> Elasticsearch7DynamicSinkITCase.testWritingDocumentsNoPrimaryKey case failed
> ----------------------------------------------------------------------------
>
> Key: FLINK-28877
> URL: https://issues.apache.org/jira/browse/FLINK-28877
> Project: Flink
> Issue Type: Bug
> Reporter: lincoln lee
> Priority: Major
> Fix For: 1.16.0
>
>
> {code}
> Aug 08 16:00:39 Caused by: java.lang.RuntimeException: An error occurred in
> ElasticsearchSink.
> Aug 08 16:00:39 at
> org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase.checkErrorAndRethrow(ElasticsearchSinkBase.java:426)
>
> Aug 08 16:00:39 at
> org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase.close(ElasticsearchSinkBase.java:365)
>
> Aug 08 16:00:39 at
> org.apache.flink.api.common.functions.util.FunctionUtils.closeFunction(FunctionUtils.java:41)
>
> Aug 08 16:00:39 at
> org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.close(AbstractUdfStreamOperator.java:114)
>
> Aug 08 16:00:39 at
> org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.close(StreamOperatorWrapper.java:163)
>
> Aug 08 16:00:39 at
> org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.closeAllOperators(RegularOperatorChain.java:125)
>
> Aug 08 16:00:39 at
> org.apache.flink.streaming.runtime.tasks.StreamTask.closeAllOperators(StreamTask.java:1022)
>
> Aug 08 16:00:39 at
> org.apache.flink.streaming.runtime.tasks.StreamTask.afterInvoke(StreamTask.java:900)
>
> Aug 08 16:00:39 at
> org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:783)
>
> Aug 08 16:00:39 at
> org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:935)
>
> Aug 08 16:00:39 at
> org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:914)
> Aug 08 16:00:39 at
> org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:728)
> Aug 08 16:00:39 at
> org.apache.flink.runtime.taskmanager.Task.run(Task.java:550)
> Aug 08 16:00:39 at java.lang.Thread.run(Thread.java:748)
> Aug 08 16:00:39 Caused by: java.net.SocketTimeoutException: 30,000
> milliseconds timeout on connection http-outgoing-0 [ACTIVE]
> Aug 08 16:00:39 at
> org.apache.http.nio.protocol.HttpAsyncRequestExecutor.timeout(HttpAsyncRequestExecutor.java:387)
>
> Aug 08 16:00:39 at
> org.apache.http.impl.nio.client.InternalIODispatch.onTimeout(InternalIODispatch.java:92)
>
> Aug 08 16:00:39 at
> org.apache.http.impl.nio.client.InternalIODispatch.onTimeout(InternalIODispatch.java:39)
>
> Aug 08 16:00:39 at
> org.apache.http.impl.nio.reactor.AbstractIODispatch.timeout(AbstractIODispatch.java:175)
>
> Aug 08 16:00:39 at
> org.apache.http.impl.nio.reactor.BaseIOReactor.sessionTimedOut(BaseIOReactor.java:261)
>
> Aug 08 16:00:39 at
> org.apache.http.impl.nio.reactor.AbstractIOReactor.timeoutCheck(AbstractIOReactor.java:502)
>
> Aug 08 16:00:39 at
> org.apache.http.impl.nio.reactor.BaseIOReactor.validate(BaseIOReactor.java:211)
>
> Aug 08 16:00:39 at
> org.apache.http.impl.nio.reactor.AbstractIOReactor.execute(AbstractIOReactor.java:280)
>
> Aug 08 16:00:39 at
> org.apache.http.impl.nio.reactor.BaseIOReactor.execute(BaseIOReactor.java:104)
>
> Aug 08 16:00:39 at
> org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor$Worker.run(AbstractMultiworkerIOReactor.java:591)
> {code}
>
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=39617&view=logs&j=4eda0b4a-bd0d-521a-0916-8285b9be9bb5&t=2ff6d5fa-53a6-53ac-bff7-fa524ea361a9
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
