lincoln lee created FLINK-28877:
-----------------------------------
Summary:
Elasticsearch7DynamicSinkITCase.testWritingDocumentsNoPrimaryKey case failed
Key: FLINK-28877
URL: https://issues.apache.org/jira/browse/FLINK-28877
Project: Flink
Issue Type: Bug
Reporter: lincoln lee
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)
