[
https://issues.apache.org/jira/browse/FLINK-20661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz reopened FLINK-20661:
--------------------------------------
> Elasticsearch6DynamicSinkITCase.testWritingDocuments test failed with
> ConnectException
> --------------------------------------------------------------------------------------
>
> Key: FLINK-20661
> URL: https://issues.apache.org/jira/browse/FLINK-20661
> Project: Flink
> Issue Type: Bug
> Components: Connectors / ElasticSearch
> Affects Versions: 1.11.0, 1.13.1
> Reporter: Huang Xingbo
> Priority: Major
> Labels: test-stability
>
> [https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=10989&view=logs&j=ba53eb01-1462-56a3-8e98-0dd97fbcaab5&t=eb5f4d19-2d2d-5856-a4ce-acf5f904a994]
> {code:java}
> 2020-12-17T22:52:41.2992508Z [ERROR] Tests run: 4, Failures: 0, Errors: 1,
> Skipped: 0, Time elapsed: 38.878 s <<< FAILURE! - in
> org.apache.flink.streaming.connectors.elasticsearch.table.Elasticsearch6DynamicSinkITCase
> 2020-12-17T22:52:41.2999076Z [ERROR]
> testWritingDocuments(org.apache.flink.streaming.connectors.elasticsearch.table.Elasticsearch6DynamicSinkITCase)
> Time elapsed: 16.409 s <<< ERROR!
> 2020-12-17T22:52:41.3008441Z
> org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
> 2020-12-17T22:52:41.3009290Z at
> org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:147)
> 2020-12-17T22:52:41.3048924Z at
> org.apache.flink.client.program.PerJobMiniClusterFactory$PerJobMiniClusterJobClient.lambda$getJobExecutionResult$2(PerJobMiniClusterFactory.java:186)
> 2020-12-17T22:52:41.3058938Z at
> java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616)
> 2020-12-17T22:52:41.3067969Z at
> java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591)
> 2020-12-17T22:52:41.3080564Z at
> java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
> 2020-12-17T22:52:41.3098938Z at
> java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
> 2020-12-17T22:52:41.3128311Z at
> org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$0(AkkaInvocationHandler.java:229)
> 2020-12-17T22:52:41.3141102Z at
> java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
> 2020-12-17T22:52:41.3168389Z at
> java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
> 2020-12-17T22:52:41.3178382Z at
> java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
> 2020-12-17T22:52:41.3179506Z at
> java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
> 2020-12-17T22:52:41.3180433Z at
> org.apache.flink.runtime.concurrent.FutureUtils$1.onComplete(FutureUtils.java:892)
> 2020-12-17T22:52:41.3181380Z at
> akka.dispatch.OnComplete.internal(Future.scala:264)
> 2020-12-17T22:52:41.3182138Z at
> akka.dispatch.OnComplete.internal(Future.scala:261)
> 2020-12-17T22:52:41.3182903Z at
> akka.dispatch.japi$CallbackBridge.apply(Future.scala:191)
> 2020-12-17T22:52:41.3183893Z at
> akka.dispatch.japi$CallbackBridge.apply(Future.scala:188)
> 2020-12-17T22:52:41.3184690Z at
> scala.concurrent.impl.CallbackRunnable.run(Promise.scala:36)
> 2020-12-17T22:52:41.3185566Z at
> org.apache.flink.runtime.concurrent.Executors$DirectExecutionContext.execute(Executors.java:74)
> 2020-12-17T22:52:41.3186546Z at
> scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:44)
> 2020-12-17T22:52:41.3187525Z at
> scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:252)
> 2020-12-17T22:52:41.3188735Z at
> akka.pattern.PromiseActorRef.$bang(AskSupport.scala:572)
> 2020-12-17T22:52:41.3189570Z at
> akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:22)
> 2020-12-17T22:52:41.3190827Z at
> akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:21)
> 2020-12-17T22:52:41.3191576Z at
> scala.concurrent.Future$$anonfun$andThen$1.apply(Future.scala:436)
> 2020-12-17T22:52:41.3192235Z at
> scala.concurrent.Future$$anonfun$andThen$1.apply(Future.scala:435)
> 2020-12-17T22:52:41.3192897Z at
> scala.concurrent.impl.CallbackRunnable.run(Promise.scala:36)
> 2020-12-17T22:52:41.3193788Z at
> akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:55)
> 2020-12-17T22:52:41.3419289Z at
> akka.dispatch.BatchingExecutor$BlockableBatch$$anonfun$run$1.apply$mcV$sp(BatchingExecutor.scala:91)
> 2020-12-17T22:52:41.3421043Z at
> akka.dispatch.BatchingExecutor$BlockableBatch$$anonfun$run$1.apply(BatchingExecutor.scala:91)
> 2020-12-17T22:52:41.3422077Z at
> akka.dispatch.BatchingExecutor$BlockableBatch$$anonfun$run$1.apply(BatchingExecutor.scala:91)
> 2020-12-17T22:52:41.3423048Z at
> scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:72)
> 2020-12-17T22:52:41.3424144Z at
> akka.dispatch.BatchingExecutor$BlockableBatch.run(BatchingExecutor.scala:90)
> 2020-12-17T22:52:41.3425029Z at
> akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:40)
> 2020-12-17T22:52:41.3426027Z at
> akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(ForkJoinExecutorConfigurator.scala:44)
> 2020-12-17T22:52:41.3426983Z at
> akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
> 2020-12-17T22:52:41.3427999Z at
> akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
> 2020-12-17T22:52:41.3429237Z at
> akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
> 2020-12-17T22:52:41.3430025Z at
> akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
> 2020-12-17T22:52:41.3430783Z Caused by:
> org.apache.flink.runtime.JobException: Recovery is suppressed by
> NoRestartBackoffTimeStrategy
> 2020-12-17T22:52:41.3431726Z at
> org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:116)
> 2020-12-17T22:52:41.3432816Z at
> org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:78)
> 2020-12-17T22:52:41.3434251Z at
> org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:192)
> 2020-12-17T22:52:41.3435057Z at
> org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:185)
> 2020-12-17T22:52:41.3435924Z at
> org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:179)
> 2020-12-17T22:52:41.3436769Z at
> org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:590)
> 2020-12-17T22:52:41.3437744Z at
> org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:384)
> 2020-12-17T22:52:41.3438444Z at
> sun.reflect.GeneratedMethodAccessor30.invoke(Unknown Source)
> 2020-12-17T22:52:41.3439123Z at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> 2020-12-17T22:52:41.3439745Z at
> java.lang.reflect.Method.invoke(Method.java:498)
> 2020-12-17T22:52:41.3440472Z at
> org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:286)
> 2020-12-17T22:52:41.3441269Z at
> org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:201)
> 2020-12-17T22:52:41.3442062Z at
> org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:74)
> 2020-12-17T22:52:41.3442920Z at
> org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:154)
> 2020-12-17T22:52:41.3508636Z at
> akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:26)
> 2020-12-17T22:52:41.3538597Z at
> akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:21)
> 2020-12-17T22:52:41.3548597Z at
> scala.PartialFunction$class.applyOrElse(PartialFunction.scala:123)
> 2020-12-17T22:52:41.3549864Z at
> akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:21)
> 2020-12-17T22:52:41.3551133Z at
> scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:170)
> 2020-12-17T22:52:41.3552005Z at
> scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
> 2020-12-17T22:52:41.3553840Z at
> scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
> 2020-12-17T22:52:41.3554709Z at
> akka.actor.Actor$class.aroundReceive(Actor.scala:517)
> 2020-12-17T22:52:41.3555545Z at
> akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:225)
> 2020-12-17T22:52:41.3556380Z at
> akka.actor.ActorCell.receiveMessage(ActorCell.scala:592)
> 2020-12-17T22:52:41.3557300Z at
> akka.actor.ActorCell.invoke(ActorCell.scala:561)
> 2020-12-17T22:52:41.3558107Z at
> akka.dispatch.Mailbox.processMailbox(Mailbox.scala:258)
> 2020-12-17T22:52:41.3558851Z at akka.dispatch.Mailbox.run(Mailbox.scala:225)
> 2020-12-17T22:52:41.3559610Z at akka.dispatch.Mailbox.exec(Mailbox.scala:235)
> 2020-12-17T22:52:41.3560207Z ... 4 more
> 2020-12-17T22:52:41.3560730Z Caused by: java.io.IOException
> 2020-12-17T22:52:41.3561479Z at
> org.elasticsearch.client.RestClient$SyncResponseListener.get(RestClient.java:728)
> 2020-12-17T22:52:41.3562379Z at
> org.elasticsearch.client.RestClient.performRequest(RestClient.java:235)
> 2020-12-17T22:52:41.3563585Z at
> org.elasticsearch.client.RestClient.performRequest(RestClient.java:198)
> 2020-12-17T22:52:41.3564527Z at
> org.elasticsearch.client.RestHighLevelClient.performRequest(RestHighLevelClient.java:522)
> 2020-12-17T22:52:41.3565451Z at
> org.elasticsearch.client.RestHighLevelClient.ping(RestHighLevelClient.java:275)
> 2020-12-17T22:52:41.3566560Z at
> org.apache.flink.streaming.connectors.elasticsearch6.Elasticsearch6ApiCallBridge.verifyClientConnection(Elasticsearch6ApiCallBridge.java:137)
> 2020-12-17T22:52:41.3568231Z at
> org.apache.flink.streaming.connectors.elasticsearch6.Elasticsearch6ApiCallBridge.verifyClientConnection(Elasticsearch6ApiCallBridge.java:47)
> 2020-12-17T22:52:41.3569261Z at
> org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase.open(ElasticsearchSinkBase.java:300)
> 2020-12-17T22:52:41.3570153Z at
> org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:36)
> 2020-12-17T22:52:41.3571019Z at
> org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:102)
> 2020-12-17T22:52:41.3572162Z at
> org.apache.flink.streaming.api.operators.StreamSink.open(StreamSink.java:48)
> 2020-12-17T22:52:41.3889038Z at
> org.apache.flink.streaming.runtime.tasks.OperatorChain.initializeStateAndOpenOperators(OperatorChain.java:291)
> 2020-12-17T22:52:41.3891041Z at
> org.apache.flink.streaming.runtime.tasks.StreamTask.lambda$beforeInvoke$1(StreamTask.java:506)
> 2020-12-17T22:52:41.3892252Z at
> org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.runThrowing(StreamTaskActionExecutor.java:47)
> 2020-12-17T22:52:41.3893464Z at
> org.apache.flink.streaming.runtime.tasks.StreamTask.beforeInvoke(StreamTask.java:475)
> 2020-12-17T22:52:41.3894531Z at
> org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:526)
> 2020-12-17T22:52:41.3895518Z at
> org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:721)
> 2020-12-17T22:52:41.3896391Z at
> org.apache.flink.runtime.taskmanager.Task.run(Task.java:546)
> 2020-12-17T22:52:41.3897343Z at java.lang.Thread.run(Thread.java:748)
> 2020-12-17T22:52:41.3898049Z Caused by: java.net.ConnectException
> 2020-12-17T22:52:41.3899197Z at
> org.apache.http.nio.pool.RouteSpecificPool.timeout(RouteSpecificPool.java:168)
> 2020-12-17T22:52:41.3900101Z at
> org.apache.http.nio.pool.AbstractNIOConnPool.requestTimeout(AbstractNIOConnPool.java:561)
> 2020-12-17T22:52:41.3900999Z at
> org.apache.http.nio.pool.AbstractNIOConnPool$InternalSessionRequestCallback.timeout(AbstractNIOConnPool.java:822)
> 2020-12-17T22:52:41.3902006Z at
> org.apache.http.impl.nio.reactor.SessionRequestImpl.timeout(SessionRequestImpl.java:183)
> 2020-12-17T22:52:41.3902924Z at
> org.apache.http.impl.nio.reactor.DefaultConnectingIOReactor.processTimeouts(DefaultConnectingIOReactor.java:210)
> 2020-12-17T22:52:41.3904492Z at
> org.apache.http.impl.nio.reactor.DefaultConnectingIOReactor.processEvents(DefaultConnectingIOReactor.java:155)
> 2020-12-17T22:52:41.3905464Z at
> org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor.execute(AbstractMultiworkerIOReactor.java:348)
> 2020-12-17T22:52:41.3906494Z at
> org.apache.http.impl.nio.conn.PoolingNHttpClientConnectionManager.execute(PoolingNHttpClientConnectionManager.java:192)
> 2020-12-17T22:52:41.3907672Z at
> org.apache.http.impl.nio.client.CloseableHttpAsyncClientBase$1.run(CloseableHttpAsyncClientBase.java:64)
> 2020-12-17T22:52:41.3908303Z ... 1 more
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
