Yun Tang created FLINK-25237:
--------------------------------
Summary: ElasticsearchSinkITCase fails due to
NoNodeAvailableException
Key: FLINK-25237
URL: https://issues.apache.org/jira/browse/FLINK-25237
Project: Flink
Issue Type: Bug
Components: Connectors / ElasticSearch, Tests
Reporter: Yun Tang
instance:
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=27900&view=logs&j=d44f43ce-542c-597d-bf94-b0718c71e5e8&t=ed165f3f-d0f6-524b-5279-86f8ee7d0e2d
{code:java}
Dec 09 17:28:50 Caused by:
ElasticsearchException[java.util.concurrent.ExecutionException:
java.net.ConnectException: Connection refused]; nested:
ExecutionException[java.net.ConnectException: Connection refused]; nested:
ConnectException[Connection refused];
Dec 09 17:28:50 at
org.elasticsearch.client.RestHighLevelClient.performClientRequest(RestHighLevelClient.java:2078)
Dec 09 17:28:50 at
org.elasticsearch.client.RestHighLevelClient.internalPerformRequest(RestHighLevelClient.java:1732)
Dec 09 17:28:50 at
org.elasticsearch.client.RestHighLevelClient.performRequest(RestHighLevelClient.java:1717)
Dec 09 17:28:50 at
org.elasticsearch.client.RestHighLevelClient.ping(RestHighLevelClient.java:815)
Dec 09 17:28:50 at
org.apache.flink.streaming.connectors.elasticsearch7.Elasticsearch7ApiCallBridge.verifyClientConnection(Elasticsearch7ApiCallBridge.java:144)
Dec 09 17:28:50 at
org.apache.flink.streaming.connectors.elasticsearch7.Elasticsearch7ApiCallBridge.verifyClientConnection(Elasticsearch7ApiCallBridge.java:46)
Dec 09 17:28:50 at
org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase.open(ElasticsearchSinkBase.java:317)
Dec 09 17:28:50 at
org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:34)
Dec 09 17:28:50 at
org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:100)
Dec 09 17:28:50 at
org.apache.flink.streaming.api.operators.StreamSink.open(StreamSink.java:46)
Dec 09 17:28:50 at
org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.initializeStateAndOpenOperators(RegularOperatorChain.java:111)
Dec 09 17:28:50 at
org.apache.flink.streaming.runtime.tasks.StreamTask.restoreGates(StreamTask.java:696)
Dec 09 17:28:50 at
org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.call(StreamTaskActionExecutor.java:55)
Dec 09 17:28:50 at
org.apache.flink.streaming.runtime.tasks.StreamTask.restoreInternal(StreamTask.java:672)
Dec 09 17:28:50 at
org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:639)
Dec 09 17:28:50 at
org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:948)
Dec 09 17:28:50 at
org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:917)
Dec 09 17:28:50 at
org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:741)
Dec 09 17:28:50 at
org.apache.flink.runtime.taskmanager.Task.run(Task.java:563)
Dec 09 17:28:50 at java.lang.Thread.run(Thread.java:748)
Dec 09 17:28:50 Caused by: java.util.concurrent.ExecutionException:
java.net.ConnectException: Connection refused
Dec 09 17:28:50 at
org.elasticsearch.common.util.concurrent.BaseFuture$Sync.getValue(BaseFuture.java:262)
Dec 09 17:28:50 at
org.elasticsearch.common.util.concurrent.BaseFuture$Sync.get(BaseFuture.java:249)
Dec 09 17:28:50 at
org.elasticsearch.common.util.concurrent.BaseFuture.get(BaseFuture.java:76)
Dec 09 17:28:50 at
org.elasticsearch.client.RestHighLevelClient.performClientRequest(RestHighLevelClient.java:2075)
Dec 09 17:28:50 ... 19 more
Dec 09 17:28:50 Caused by: java.net.ConnectException: Connection refused
Dec 09 17:28:50 at sun.nio.ch.SocketChannelImpl.checkConnect(Native
Method)
Dec 09 17:28:50 at
sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:716)
Dec 09 17:28:50 at
org.apache.http.impl.nio.reactor.DefaultConnectingIOReactor.processEvent(DefaultConnectingIOReactor.java:174)
Dec 09 17:28:50 at
org.apache.http.impl.nio.reactor.DefaultConnectingIOReactor.processEvents(DefaultConnectingIOReactor.java:148)
Dec 09 17:28:50 at
org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor.execute(AbstractMultiworkerIOReactor.java:351)
Dec 09 17:28:50 at
org.apache.http.impl.nio.conn.PoolingNHttpClientConnectionManager.execute(PoolingNHttpClientConnectionManager.java:221)
Dec 09 17:28:50 at
org.apache.http.impl.nio.client.CloseableHttpAsyncClientBase$1.run(CloseableHttpAsyncClientBase.java:64)
Dec 09 17:28:50 ... 1 more
{code}
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
