You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/01/31 02:12:00 UTC
[jira] [Commented] (FLINK-20661)
Elasticsearch6DynamicSinkITCase.testWritingDocuments test failed with
ConnectException
[ https://issues.apache.org/jira/browse/FLINK-20661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17275757#comment-17275757 ]
Guowei Ma commented on FLINK-20661:
-----------------------------------
[https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=12700&view=logs&j=d44f43ce-542c-597d-bf94-b0718c71e5e8&t=34f486e1-e1e4-5dd2-9c06-bfdd9b9c74a8]
Caused by: org.elasticsearch.ElasticsearchStatusException: method [HEAD], host [[http://127.0.0.1:9200],|http://127.0.0.1:9200]%2C/] URI [/], status line [HTTP/1.1 503 Service Unavailable]
at org.elasticsearch.client.RestHighLevelClient.parseResponseException(RestHighLevelClient.java:625)
at org.elasticsearch.client.RestHighLevelClient.performRequest(RestHighLevelClient.java:535)
at org.elasticsearch.client.RestHighLevelClient.ping(RestHighLevelClient.java:275)
at org.apache.flink.streaming.connectors.elasticsearch6.Elasticsearch6ApiCallBridge.verifyClientConnection(Elasticsearch6ApiCallBridge.java:134)
at org.apache.flink.streaming.connectors.elasticsearch6.Elasticsearch6ApiCallBridge.verifyClientConnection(Elasticsearch6ApiCallBridge.java:45)
at org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase.open(ElasticsearchSinkBase.java:322)
at org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:34)
at org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:102)
at org.apache.flink.table.runtime.operators.sink.SinkOperator.open(SinkOperator.java:74)
at org.apache.flink.streaming.runtime.tasks.OperatorChain.initializeStateAndOpenOperators(OperatorChain.java:307)
at org.apache.flink.streaming.runtime.tasks.StreamTask.lambda$beforeInvoke$1(StreamTask.java:537)
at org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$SynchronizedStreamTaskActionExecutor.runThrowing(StreamTaskActionExecutor.java:93)
at org.apache.flink.streaming.runtime.tasks.StreamTask.beforeInvoke(StreamTask.java:495)
at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:558)
at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:752)
at org.apache.flink.runtime.taskmanager.Task.run(Task.jav
> 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.12.0, 1.13.0
> 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)