You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "macdoor615 (Jira)" <ji...@apache.org> on 2022/04/23 05:25:00 UTC
[jira] [Commented] (FLINK-25691) ElasticsearchSinkITCase.testElasticsearchSink fails on AZP
[ https://issues.apache.org/jira/browse/FLINK-25691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17526768#comment-17526768 ]
macdoor615 commented on FLINK-25691:
------------------------------------
[~alexanderpreuss] [~martijnvisser]
We are facing the same problem and can not reproduce.
Maybe you can refer to this case.
He suspects that the ES cluster will cause the http long connection dead during the OldGC, and will not create a new connection, causing the data refresh ES to time out.
https://blog.csdn.net/HugeBitter/article/details/119823989
> ElasticsearchSinkITCase.testElasticsearchSink fails on AZP
> ----------------------------------------------------------
>
> Key: FLINK-25691
> URL: https://issues.apache.org/jira/browse/FLINK-25691
> Project: Flink
> Issue Type: Bug
> Components: Connectors / ElasticSearch
> Affects Versions: 1.15.0
> Reporter: Till Rohrmann
> Priority: Major
> Labels: auto-deprioritized-critical, stale-major, test-stability
>
> The test {{ElasticsearchSinkITCase.testElasticsearchSink}} fails on AZP with
> {code}
> 2022-01-18T08:10:11.9777311Z Jan 18 08:10:11 [ERROR] org.apache.flink.streaming.connectors.elasticsearch7.ElasticsearchSinkITCase.testElasticsearchSink Time elapsed: 31.816 s <<< ERROR!
> 2022-01-18T08:10:11.9778438Z Jan 18 08:10:11 org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
> 2022-01-18T08:10:11.9779184Z Jan 18 08:10:11 at org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144)
> 2022-01-18T08:10:11.9779993Z Jan 18 08:10:11 at org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$3(MiniClusterJobClient.java:137)
> 2022-01-18T08:10:11.9780892Z Jan 18 08:10:11 at java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616)
> 2022-01-18T08:10:11.9781726Z Jan 18 08:10:11 at java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591)
> 2022-01-18T08:10:11.9782380Z Jan 18 08:10:11 at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
> 2022-01-18T08:10:11.9783097Z Jan 18 08:10:11 at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
> 2022-01-18T08:10:11.9783866Z Jan 18 08:10:11 at org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$1(AkkaInvocationHandler.java:258)
> 2022-01-18T08:10:11.9784615Z Jan 18 08:10:11 at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
> 2022-01-18T08:10:11.9791362Z Jan 18 08:10:11 at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
> 2022-01-18T08:10:11.9792139Z Jan 18 08:10:11 at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
> 2022-01-18T08:10:11.9793011Z Jan 18 08:10:11 at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
> 2022-01-18T08:10:11.9793620Z Jan 18 08:10:11 at org.apache.flink.util.concurrent.FutureUtils.doForward(FutureUtils.java:1389)
> 2022-01-18T08:10:11.9794267Z Jan 18 08:10:11 at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$null$1(ClassLoadingUtils.java:93)
> 2022-01-18T08:10:11.9795177Z Jan 18 08:10:11 at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68)
> 2022-01-18T08:10:11.9796451Z Jan 18 08:10:11 at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$guardCompletionWithContextClassLoader$2(ClassLoadingUtils.java:92)
> 2022-01-18T08:10:11.9797325Z Jan 18 08:10:11 at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
> 2022-01-18T08:10:11.9798108Z Jan 18 08:10:11 at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
> 2022-01-18T08:10:11.9798749Z Jan 18 08:10:11 at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
> 2022-01-18T08:10:11.9799364Z Jan 18 08:10:11 at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
> 2022-01-18T08:10:11.9799990Z Jan 18 08:10:11 at org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$1.onComplete(AkkaFutureUtils.java:47)
> 2022-01-18T08:10:11.9800561Z Jan 18 08:10:11 at akka.dispatch.OnComplete.internal(Future.scala:300)
> 2022-01-18T08:10:11.9801061Z Jan 18 08:10:11 at akka.dispatch.OnComplete.internal(Future.scala:297)
> 2022-01-18T08:10:11.9801661Z Jan 18 08:10:11 at akka.dispatch.japi$CallbackBridge.apply(Future.scala:224)
> 2022-01-18T08:10:11.9802186Z Jan 18 08:10:11 at akka.dispatch.japi$CallbackBridge.apply(Future.scala:221)
> 2022-01-18T08:10:11.9802713Z Jan 18 08:10:11 at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60)
> 2022-01-18T08:10:11.9803348Z Jan 18 08:10:11 at org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$DirectExecutionContext.execute(AkkaFutureUtils.java:65)
> 2022-01-18T08:10:11.9804008Z Jan 18 08:10:11 at scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:68)
> 2022-01-18T08:10:11.9804600Z Jan 18 08:10:11 at scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1(Promise.scala:284)
> 2022-01-18T08:10:11.9805253Z Jan 18 08:10:11 at scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1$adapted(Promise.scala:284)
> 2022-01-18T08:10:11.9805882Z Jan 18 08:10:11 at scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:284)
> 2022-01-18T08:10:11.9806617Z Jan 18 08:10:11 at akka.pattern.PromiseActorRef.$bang(AskSupport.scala:621)
> 2022-01-18T08:10:11.9807657Z Jan 18 08:10:11 at akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:24)
> 2022-01-18T08:10:11.9808801Z Jan 18 08:10:11 at akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:23)
> 2022-01-18T08:10:11.9809475Z Jan 18 08:10:11 at scala.concurrent.Future.$anonfun$andThen$1(Future.scala:532)
> 2022-01-18T08:10:11.9810015Z Jan 18 08:10:11 at scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:29)
> 2022-01-18T08:10:11.9810555Z Jan 18 08:10:11 at scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:29)
> 2022-01-18T08:10:11.9811138Z Jan 18 08:10:11 at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60)
> 2022-01-18T08:10:11.9812121Z Jan 18 08:10:11 at akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:63)
> 2022-01-18T08:10:11.9812866Z Jan 18 08:10:11 at akka.dispatch.BatchingExecutor$BlockableBatch.$anonfun$run$1(BatchingExecutor.scala:100)
> 2022-01-18T08:10:11.9813752Z Jan 18 08:10:11 at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:12)
> 2022-01-18T08:10:11.9814671Z Jan 18 08:10:11 at scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:81)
> 2022-01-18T08:10:11.9815468Z Jan 18 08:10:11 at akka.dispatch.BatchingExecutor$BlockableBatch.run(BatchingExecutor.scala:100)
> 2022-01-18T08:10:11.9816519Z Jan 18 08:10:11 at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:49)
> 2022-01-18T08:10:11.9817463Z Jan 18 08:10:11 at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(ForkJoinExecutorConfigurator.scala:48)
> 2022-01-18T08:10:11.9818345Z Jan 18 08:10:11 at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
> 2022-01-18T08:10:11.9818925Z Jan 18 08:10:11 at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056)
> 2022-01-18T08:10:11.9819753Z Jan 18 08:10:11 at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692)
> 2022-01-18T08:10:11.9820746Z Jan 18 08:10:11 at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175)
> 2022-01-18T08:10:11.9821534Z Jan 18 08:10:11 Caused by: org.apache.flink.runtime.JobException: Recovery is suppressed by NoRestartBackoffTimeStrategy
> 2022-01-18T08:10:11.9822663Z Jan 18 08:10:11 at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:138)
> 2022-01-18T08:10:11.9823857Z Jan 18 08:10:11 at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:82)
> 2022-01-18T08:10:11.9824947Z Jan 18 08:10:11 at org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:253)
> 2022-01-18T08:10:11.9825947Z Jan 18 08:10:11 at org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:243)
> 2022-01-18T08:10:11.9826970Z Jan 18 08:10:11 at org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:234)
> 2022-01-18T08:10:11.9827987Z Jan 18 08:10:11 at org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:814)
> 2022-01-18T08:10:11.9828976Z Jan 18 08:10:11 at org.apache.flink.runtime.scheduler.SchedulerNG.updateTaskExecutionState(SchedulerNG.java:79)
> 2022-01-18T08:10:11.9829658Z Jan 18 08:10:11 at org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:445)
> 2022-01-18T08:10:11.9830227Z Jan 18 08:10:11 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> 2022-01-18T08:10:11.9830771Z Jan 18 08:10:11 at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> 2022-01-18T08:10:11.9831579Z Jan 18 08:10:11 at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> 2022-01-18T08:10:11.9832539Z Jan 18 08:10:11 at java.lang.reflect.Method.invoke(Method.java:498)
> 2022-01-18T08:10:11.9833428Z Jan 18 08:10:11 at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRpcInvocation$1(AkkaRpcActor.java:316)
> 2022-01-18T08:10:11.9834483Z Jan 18 08:10:11 at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83)
> 2022-01-18T08:10:11.9835603Z Jan 18 08:10:11 at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:314)
> 2022-01-18T08:10:11.9836565Z Jan 18 08:10:11 at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:217)
> 2022-01-18T08:10:11.9837544Z Jan 18 08:10:11 at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:78)
> 2022-01-18T08:10:11.9838651Z Jan 18 08:10:11 at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:163)
> 2022-01-18T08:10:11.9839507Z Jan 18 08:10:11 at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24)
> 2022-01-18T08:10:11.9840283Z Jan 18 08:10:11 at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20)
> 2022-01-18T08:10:11.9841052Z Jan 18 08:10:11 at scala.PartialFunction.applyOrElse(PartialFunction.scala:123)
> 2022-01-18T08:10:11.9841845Z Jan 18 08:10:11 at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122)
> 2022-01-18T08:10:11.9842404Z Jan 18 08:10:11 at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20)
> 2022-01-18T08:10:11.9843165Z Jan 18 08:10:11 at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
> 2022-01-18T08:10:11.9844023Z Jan 18 08:10:11 at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
> 2022-01-18T08:10:11.9844950Z Jan 18 08:10:11 at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
> 2022-01-18T08:10:11.9845616Z Jan 18 08:10:11 at akka.actor.Actor.aroundReceive(Actor.scala:537)
> 2022-01-18T08:10:11.9846111Z Jan 18 08:10:11 at akka.actor.Actor.aroundReceive$(Actor.scala:535)
> 2022-01-18T08:10:11.9846616Z Jan 18 08:10:11 at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220)
> 2022-01-18T08:10:11.9847326Z Jan 18 08:10:11 at akka.actor.ActorCell.receiveMessage(ActorCell.scala:580)
> 2022-01-18T08:10:11.9847985Z Jan 18 08:10:11 at akka.actor.ActorCell.invoke(ActorCell.scala:548)
> 2022-01-18T08:10:11.9848496Z Jan 18 08:10:11 at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270)
> 2022-01-18T08:10:11.9848999Z Jan 18 08:10:11 at akka.dispatch.Mailbox.run(Mailbox.scala:231)
> 2022-01-18T08:10:11.9849485Z Jan 18 08:10:11 at akka.dispatch.Mailbox.exec(Mailbox.scala:243)
> 2022-01-18T08:10:11.9849872Z Jan 18 08:10:11 ... 4 more
> 2022-01-18T08:10:11.9850315Z Jan 18 08:10:11 Caused by: java.lang.RuntimeException: An error occurred in ElasticsearchSink.
> 2022-01-18T08:10:11.9850998Z Jan 18 08:10:11 at org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase.checkErrorAndRethrow(ElasticsearchSinkBase.java:426)
> 2022-01-18T08:10:11.9851881Z Jan 18 08:10:11 at org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase.checkAsyncErrorsAndRequests(ElasticsearchSinkBase.java:431)
> 2022-01-18T08:10:11.9852659Z Jan 18 08:10:11 at org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase.invoke(ElasticsearchSinkBase.java:328)
> 2022-01-18T08:10:11.9853337Z Jan 18 08:10:11 at org.apache.flink.streaming.api.operators.StreamSink.processElement(StreamSink.java:54)
> 2022-01-18T08:10:11.9854039Z Jan 18 08:10:11 at org.apache.flink.streaming.runtime.tasks.OneInputStreamTask$StreamTaskNetworkOutput.emitRecord(OneInputStreamTask.java:233)
> 2022-01-18T08:10:11.9854816Z Jan 18 08:10:11 at org.apache.flink.streaming.runtime.io.AbstractStreamTaskNetworkInput.processElement(AbstractStreamTaskNetworkInput.java:134)
> 2022-01-18T08:10:11.9855744Z Jan 18 08:10:11 at org.apache.flink.streaming.runtime.io.AbstractStreamTaskNetworkInput.emitNext(AbstractStreamTaskNetworkInput.java:105)
> 2022-01-18T08:10:11.9856956Z Jan 18 08:10:11 at org.apache.flink.streaming.runtime.io.StreamOneInputProcessor.processInput(StreamOneInputProcessor.java:65)
> 2022-01-18T08:10:11.9857728Z Jan 18 08:10:11 at org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:517)
> 2022-01-18T08:10:11.9858398Z Jan 18 08:10:11 at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:203)
> 2022-01-18T08:10:11.9859070Z Jan 18 08:10:11 at org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:802)
> 2022-01-18T08:10:11.9859697Z Jan 18 08:10:11 at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:751)
> 2022-01-18T08:10:11.9860307Z Jan 18 08:10:11 at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:948)
> 2022-01-18T08:10:11.9860910Z Jan 18 08:10:11 at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:927)
> 2022-01-18T08:10:11.9861546Z Jan 18 08:10:11 at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:741)
> 2022-01-18T08:10:11.9862075Z Jan 18 08:10:11 at org.apache.flink.runtime.taskmanager.Task.run(Task.java:563)
> 2022-01-18T08:10:11.9862565Z Jan 18 08:10:11 at java.lang.Thread.run(Thread.java:748)
> 2022-01-18T08:10:11.9863072Z Jan 18 08:10:11 Suppressed: java.lang.RuntimeException: An error occurred in ElasticsearchSink.
> 2022-01-18T08:10:11.9863761Z Jan 18 08:10:11 at org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase.checkErrorAndRethrow(ElasticsearchSinkBase.java:426)
> 2022-01-18T08:10:11.9864662Z Jan 18 08:10:11 at org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase.close(ElasticsearchSinkBase.java:365)
> 2022-01-18T08:10:11.9865357Z Jan 18 08:10:11 at org.apache.flink.api.common.functions.util.FunctionUtils.closeFunction(FunctionUtils.java:41)
> 2022-01-18T08:10:11.9866051Z Jan 18 08:10:11 at org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.close(AbstractUdfStreamOperator.java:114)
> 2022-01-18T08:10:11.9866853Z Jan 18 08:10:11 at org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.close(StreamOperatorWrapper.java:163)
> 2022-01-18T08:10:11.9867790Z Jan 18 08:10:11 at org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.closeAllOperators(RegularOperatorChain.java:125)
> 2022-01-18T08:10:11.9868947Z Jan 18 08:10:11 at org.apache.flink.streaming.runtime.tasks.StreamTask.closeAllOperators(StreamTask.java:995)
> 2022-01-18T08:10:11.9869583Z Jan 18 08:10:11 at org.apache.flink.util.IOUtils.closeAll(IOUtils.java:254)
> 2022-01-18T08:10:11.9870175Z Jan 18 08:10:11 at org.apache.flink.core.fs.AutoCloseableRegistry.doClose(AutoCloseableRegistry.java:72)
> 2022-01-18T08:10:11.9870832Z Jan 18 08:10:11 at org.apache.flink.util.AbstractAutoCloseableRegistry.close(AbstractAutoCloseableRegistry.java:127)
> 2022-01-18T08:10:11.9871537Z Jan 18 08:10:11 at org.apache.flink.streaming.runtime.tasks.StreamTask.cleanUp(StreamTask.java:914)
> 2022-01-18T08:10:11.9872163Z Jan 18 08:10:11 at org.apache.flink.runtime.taskmanager.Task.lambda$restoreAndInvoke$0(Task.java:930)
> 2022-01-18T08:10:11.9872780Z Jan 18 08:10:11 at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:948)
> 2022-01-18T08:10:11.9873382Z Jan 18 08:10:11 at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:930)
> 2022-01-18T08:10:11.9873824Z Jan 18 08:10:11 ... 3 more
> 2022-01-18T08:10:11.9874816Z Jan 18 08:10:11 Caused by: java.net.SocketTimeoutException: 30,000 milliseconds timeout on connection http-outgoing-2 [ACTIVE]
> 2022-01-18T08:10:11.9875510Z Jan 18 08:10:11 at org.apache.http.nio.protocol.HttpAsyncRequestExecutor.timeout(HttpAsyncRequestExecutor.java:387)
> 2022-01-18T08:10:11.9876176Z Jan 18 08:10:11 at org.apache.http.impl.nio.client.InternalIODispatch.onTimeout(InternalIODispatch.java:92)
> 2022-01-18T08:10:11.9876823Z Jan 18 08:10:11 at org.apache.http.impl.nio.client.InternalIODispatch.onTimeout(InternalIODispatch.java:39)
> 2022-01-18T08:10:11.9877473Z Jan 18 08:10:11 at org.apache.http.impl.nio.reactor.AbstractIODispatch.timeout(AbstractIODispatch.java:175)
> 2022-01-18T08:10:11.9878208Z Jan 18 08:10:11 at org.apache.http.impl.nio.reactor.BaseIOReactor.sessionTimedOut(BaseIOReactor.java:261)
> 2022-01-18T08:10:11.9878842Z Jan 18 08:10:11 at org.apache.http.impl.nio.reactor.AbstractIOReactor.timeoutCheck(AbstractIOReactor.java:502)
> 2022-01-18T08:10:11.9879551Z Jan 18 08:10:11 at org.apache.http.impl.nio.reactor.BaseIOReactor.validate(BaseIOReactor.java:211)
> 2022-01-18T08:10:11.9880586Z Jan 18 08:10:11 at org.apache.http.impl.nio.reactor.AbstractIOReactor.execute(AbstractIOReactor.java:280)
> 2022-01-18T08:10:11.9881488Z Jan 18 08:10:11 at org.apache.http.impl.nio.reactor.BaseIOReactor.execute(BaseIOReactor.java:104)
> 2022-01-18T08:10:11.9882161Z Jan 18 08:10:11 at org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor$Worker.run(AbstractMultiworkerIOReactor.java:591)
> 2022-01-18T08:10:11.9882692Z Jan 18 08:10:11 ... 1 more
> 2022-01-18T08:10:11.9883528Z Jan 18 08:10:11 Caused by: [CIRCULAR REFERENCE: java.net.SocketTimeoutException: 30,000 milliseconds timeout on connection http-outgoing-2 [ACTIVE]]
> 2022-01-18T08:10:11.9884052Z Jan 18 08:10:11
> 2022-01-18T08:10:12.3944273Z Jan 18 08:10:12 [INFO]
> 2022-01-18T08:10:12.3944771Z Jan 18 08:10:12 [INFO] Results:
> 2022-01-18T08:10:12.3945115Z Jan 18 08:10:12 [INFO]
> 2022-01-18T08:10:12.3945449Z Jan 18 08:10:12 [ERROR] Errors:
> 2022-01-18T08:10:12.3946628Z Jan 18 08:10:12 [ERROR] ElasticsearchSinkITCase.testElasticsearchSink » JobExecution Job execution fai...
> 2022-01-18T08:10:12.3947902Z Jan 18 08:10:12 [INFO]
> 2022-01-18T08:10:12.3948326Z Jan 18 08:10:12 [ERROR] Tests run: 15, Failures: 0, Errors: 1, Skipped: 0
> {code}
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=29616&view=logs&j=d44f43ce-542c-597d-bf94-b0718c71e5e8&t=ed165f3f-d0f6-524b-5279-86f8ee7d0e2d&l=12607
--
This message was sent by Atlassian Jira
(v8.20.7#820007)