Huang Xingbo created FLINK-20661:
------------------------------------
Summary: 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.12.0, 1.11.0, 1.13.0
Reporter: Huang Xingbo
[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)
