[
https://issues.apache.org/jira/browse/FLINK-21652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guowei Ma updated FLINK-21652:
------------------------------
Summary: Elasticsearch6DynamicSinkITCase.testWritingDocumentsFromTableApi
failed because of throwing SocketTimeoutException during the closing stage.
(was: Elasticsearch6DynamicSinkITCase.testWritingDocumentsFromTableApi failed
because of throwing SocketTimeOut Exception during closing stage.)
> Elasticsearch6DynamicSinkITCase.testWritingDocumentsFromTableApi failed
> because of throwing SocketTimeoutException during the closing stage.
> --------------------------------------------------------------------------------------------------------------------------------------------
>
> Key: FLINK-21652
> URL: https://issues.apache.org/jira/browse/FLINK-21652
> Project: Flink
> Issue Type: Bug
> Components: Connectors / ElasticSearch
> Affects Versions: 1.13.0
> Reporter: Guowei Ma
> Priority: Major
> Labels: test-stability
>
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=14263&view=logs&j=3d12d40f-c62d-5ec4-6acc-0efe94cc3e89&t=5d6e4255-0ea8-5e2a-f52c-c881b7872361
> {code:java}
> 2021-03-07T23:12:11.0702985Z [ERROR]
> testWritingDocumentsFromTableApi(org.apache.flink.streaming.connectors.elasticsearch.table.Elasticsearch6DynamicSinkITCase)
> Time elapsed: 31.256 s <<< ERROR!
> 2021-03-07T23:12:11.0704247Z java.util.concurrent.ExecutionException:
> org.apache.flink.table.api.TableException: Failed to wait job finish
> 2021-03-07T23:12:11.0705203Z at
> java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357)
> 2021-03-07T23:12:11.0705982Z at
> java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1908)
> 2021-03-07T23:12:11.0706791Z at
> org.apache.flink.table.api.internal.TableResultImpl.awaitInternal(TableResultImpl.java:123)
> 2021-03-07T23:12:11.0707583Z at
> org.apache.flink.table.api.internal.TableResultImpl.await(TableResultImpl.java:86)
> 2021-03-07T23:12:11.0708850Z at
> org.apache.flink.streaming.connectors.elasticsearch.table.Elasticsearch6DynamicSinkITCase.testWritingDocumentsFromTableApi(Elasticsearch6DynamicSinkITCase.java:205)
> 2021-03-07T23:12:11.0709804Z at
> sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> 2021-03-07T23:12:11.0710479Z at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> 2021-03-07T23:12:11.0711251Z at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> 2021-03-07T23:12:11.0711974Z at
> java.lang.reflect.Method.invoke(Method.java:498)
> 2021-03-07T23:12:11.0712663Z at
> org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
> 2021-03-07T23:12:11.0713466Z at
> org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
> 2021-03-07T23:12:11.0715464Z at
> org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
> 2021-03-07T23:12:11.0716070Z at
> org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
> 2021-03-07T23:12:11.0716576Z at
> org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
> 2021-03-07T23:12:11.0717278Z at
> org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
> 2021-03-07T23:12:11.0717873Z at
> org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
> 2021-03-07T23:12:11.0718540Z at
> org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
> 2021-03-07T23:12:11.0718940Z at
> org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
> 2021-03-07T23:12:11.0719362Z at
> org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
> 2021-03-07T23:12:11.0719792Z at
> org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
> 2021-03-07T23:12:11.0720207Z at
> org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
> 2021-03-07T23:12:11.0720728Z at
> org.testcontainers.containers.FailureDetectingExternalResource$1.evaluate(FailureDetectingExternalResource.java:30)
> 2021-03-07T23:12:11.0721353Z at
> org.junit.rules.RunRules.evaluate(RunRules.java:20)
> 2021-03-07T23:12:11.0721940Z at
> org.junit.runners.ParentRunner.run(ParentRunner.java:363)
> 2021-03-07T23:12:11.0753352Z at
> org.apache.maven.surefire.junit4.JUnit4Provider.execute(JUnit4Provider.java:365)
> 2021-03-07T23:12:11.0754394Z at
> org.apache.maven.surefire.junit4.JUnit4Provider.executeWithRerun(JUnit4Provider.java:273)
> 2021-03-07T23:12:11.0755260Z at
> org.apache.maven.surefire.junit4.JUnit4Provider.executeTestSet(JUnit4Provider.java:238)
> 2021-03-07T23:12:11.0756131Z at
> org.apache.maven.surefire.junit4.JUnit4Provider.invoke(JUnit4Provider.java:159)
> 2021-03-07T23:12:11.0757021Z at
> org.apache.maven.surefire.booter.ForkedBooter.invokeProviderInSameClassLoader(ForkedBooter.java:384)
> 2021-03-07T23:12:11.0758317Z at
> org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:345)
> 2021-03-07T23:12:11.0759162Z at
> org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:126)
> 2021-03-07T23:12:11.0760036Z at
> org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:418)
> 2021-03-07T23:12:11.0760719Z Caused by:
> org.apache.flink.table.api.TableException: Failed to wait job finish
> 2021-03-07T23:12:11.0761710Z at
> org.apache.flink.table.api.internal.InsertResultIterator.hasNext(InsertResultIterator.java:56)
> 2021-03-07T23:12:11.0762716Z at
> org.apache.flink.table.api.internal.TableResultImpl$CloseableRowIteratorWrapper.hasNext(TableResultImpl.java:350)
> 2021-03-07T23:12:11.0763664Z at
> org.apache.flink.table.api.internal.TableResultImpl$CloseableRowIteratorWrapper.isFirstRowReady(TableResultImpl.java:363)
> 2021-03-07T23:12:11.0764688Z at
> org.apache.flink.table.api.internal.TableResultImpl.lambda$awaitInternal$1(TableResultImpl.java:110)
> 2021-03-07T23:12:11.0765629Z at
> java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1640)
> 2021-03-07T23:12:11.0766347Z at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
> 2021-03-07T23:12:11.0767111Z at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> 2021-03-07T23:12:11.0768502Z at java.lang.Thread.run(Thread.java:748)
> 2021-03-07T23:12:11.0769543Z Caused by:
> java.util.concurrent.ExecutionException:
> org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
> 2021-03-07T23:12:11.0770639Z at
> java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357)
> 2021-03-07T23:12:11.0771323Z at
> java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1908)
> 2021-03-07T23:12:11.0772146Z at
> org.apache.flink.table.api.internal.InsertResultIterator.hasNext(InsertResultIterator.java:54)
> 2021-03-07T23:12:11.0772729Z ... 7 more
> 2021-03-07T23:12:11.0773353Z Caused by:
> org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
> 2021-03-07T23:12:11.0774275Z at
> org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144)
> 2021-03-07T23:12:11.0775061Z at
> org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$3(MiniClusterJobClient.java:137)
> 2021-03-07T23:12:11.0776067Z at
> java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616)
> 2021-03-07T23:12:11.0776767Z at
> java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591)
> 2021-03-07T23:12:11.0777806Z at
> java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
> 2021-03-07T23:12:11.0779223Z at
> java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
> 2021-03-07T23:12:11.0780706Z at
> org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$0(AkkaInvocationHandler.java:237)
> 2021-03-07T23:12:11.0781595Z at
> java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
> 2021-03-07T23:12:11.0782463Z at
> java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
> 2021-03-07T23:12:11.0783408Z at
> java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
> 2021-03-07T23:12:11.0784329Z at
> java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
> 2021-03-07T23:12:11.0785137Z at
> org.apache.flink.runtime.concurrent.FutureUtils$1.onComplete(FutureUtils.java:1066)
> 2021-03-07T23:12:11.0786373Z at
> akka.dispatch.OnComplete.internal(Future.scala:264)
> 2021-03-07T23:12:11.0786953Z at
> akka.dispatch.OnComplete.internal(Future.scala:261)
> 2021-03-07T23:12:11.0788651Z at
> akka.dispatch.japi$CallbackBridge.apply(Future.scala:191)
> 2021-03-07T23:12:11.0789381Z at
> akka.dispatch.japi$CallbackBridge.apply(Future.scala:188)
> 2021-03-07T23:12:11.0790039Z at
> scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60)
> 2021-03-07T23:12:11.0790783Z at
> org.apache.flink.runtime.concurrent.Executors$DirectExecutionContext.execute(Executors.java:73)
> 2021-03-07T23:12:11.0791736Z at
> scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:68)
> 2021-03-07T23:12:11.0792448Z at
> scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1(Promise.scala:284)
> 2021-03-07T23:12:11.0793339Z at
> scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1$adapted(Promise.scala:284)
> 2021-03-07T23:12:11.0794615Z at
> scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:284)
> 2021-03-07T23:12:11.0795258Z at
> akka.pattern.PromiseActorRef.$bang(AskSupport.scala:573)
> 2021-03-07T23:12:11.0795964Z at
> akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:22)
> 2021-03-07T23:12:11.0796767Z at
> akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:21)
> 2021-03-07T23:12:11.0797439Z at
> scala.concurrent.Future.$anonfun$andThen$1(Future.scala:532)
> 2021-03-07T23:12:11.0798174Z at
> scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:29)
> 2021-03-07T23:12:11.0798787Z at
> scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:29)
> 2021-03-07T23:12:11.0799407Z at
> scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60)
> 2021-03-07T23:12:11.0800068Z at
> akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:55)
> 2021-03-07T23:12:11.0800765Z at
> akka.dispatch.BatchingExecutor$BlockableBatch.$anonfun$run$1(BatchingExecutor.scala:91)
> 2021-03-07T23:12:11.0802135Z at
> scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:12)
> 2021-03-07T23:12:11.0802828Z at
> scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:81)
> 2021-03-07T23:12:11.0803570Z at
> akka.dispatch.BatchingExecutor$BlockableBatch.run(BatchingExecutor.scala:91)
> 2021-03-07T23:12:11.0804393Z at
> akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:40)
> 2021-03-07T23:12:11.0805218Z at
> akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(ForkJoinExecutorConfigurator.scala:44)
> 2021-03-07T23:12:11.0806196Z at
> akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
> 2021-03-07T23:12:11.0806951Z at
> akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
> 2021-03-07T23:12:11.0807778Z at
> akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
> 2021-03-07T23:12:11.0808729Z at
> akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
> 2021-03-07T23:12:11.0809575Z Caused by:
> org.apache.flink.runtime.JobException: Recovery is suppressed by
> NoRestartBackoffTimeStrategy
> 2021-03-07T23:12:11.0810594Z at
> org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:130)
> 2021-03-07T23:12:11.0811630Z at
> org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:81)
> 2021-03-07T23:12:11.0812617Z at
> org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:221)
> 2021-03-07T23:12:11.0813520Z at
> org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:212)
> 2021-03-07T23:12:11.0814551Z at
> org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:203)
> 2021-03-07T23:12:11.0815428Z at
> org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:699)
> 2021-03-07T23:12:11.0816262Z at
> org.apache.flink.runtime.scheduler.SchedulerNG.updateTaskExecutionState(SchedulerNG.java:80)
> 2021-03-07T23:12:11.0817295Z at
> org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:433)
> 2021-03-07T23:12:11.0817957Z at
> sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> 2021-03-07T23:12:11.0819072Z at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> 2021-03-07T23:12:11.0820070Z at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> 2021-03-07T23:12:11.0820725Z at
> java.lang.reflect.Method.invoke(Method.java:498)
> 2021-03-07T23:12:11.0821584Z at
> org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:305)
> 2021-03-07T23:12:11.0822329Z at
> org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:212)
> 2021-03-07T23:12:11.0823074Z at
> org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:77)
> 2021-03-07T23:12:11.0823988Z at
> org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:158)
> 2021-03-07T23:12:11.0824670Z at
> akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:26)
> 2021-03-07T23:12:11.0825245Z at
> akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:21)
> 2021-03-07T23:12:11.0825861Z at
> scala.PartialFunction.applyOrElse(PartialFunction.scala:123)
> 2021-03-07T23:12:11.0826472Z at
> scala.PartialFunction.applyOrElse$(PartialFunction.scala:122)
> 2021-03-07T23:12:11.0827065Z at
> akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:21)
> 2021-03-07T23:12:11.0827739Z at
> scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
> 2021-03-07T23:12:11.0828590Z at
> scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
> 2021-03-07T23:12:11.0829321Z at
> scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
> 2021-03-07T23:12:11.0829992Z at
> akka.actor.Actor.aroundReceive(Actor.scala:517)
> 2021-03-07T23:12:11.0830572Z at
> akka.actor.Actor.aroundReceive$(Actor.scala:515)
> 2021-03-07T23:12:11.0831247Z at
> akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:225)
> 2021-03-07T23:12:11.0831951Z at
> akka.actor.ActorCell.receiveMessage(ActorCell.scala:592)
> 2021-03-07T23:12:11.0833131Z at
> akka.actor.ActorCell.invoke(ActorCell.scala:561)
> 2021-03-07T23:12:11.0833872Z at
> akka.dispatch.Mailbox.processMailbox(Mailbox.scala:258)
> 2021-03-07T23:12:11.0834498Z at akka.dispatch.Mailbox.run(Mailbox.scala:225)
> 2021-03-07T23:12:11.0835061Z at akka.dispatch.Mailbox.exec(Mailbox.scala:235)
> 2021-03-07T23:12:11.0835505Z ... 4 more
> 2021-03-07T23:12:11.0836167Z Caused by:
> java.util.concurrent.ExecutionException: java.lang.RuntimeException: An error
> occurred in ElasticsearchSink.
> 2021-03-07T23:12:11.0836942Z at
> java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357)
> 2021-03-07T23:12:11.0837720Z at
> java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1928)
> 2021-03-07T23:12:11.0839411Z at
> org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.quiesceTimeServiceAndCloseOperator(StreamOperatorWrapper.java:168)
> 2021-03-07T23:12:11.0840363Z at
> org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.close(StreamOperatorWrapper.java:131)
> 2021-03-07T23:12:11.0841225Z at
> org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.close(StreamOperatorWrapper.java:135)
> 2021-03-07T23:12:11.0842084Z at
> org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.close(StreamOperatorWrapper.java:135)
> 2021-03-07T23:12:11.0843072Z at
> org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.close(StreamOperatorWrapper.java:135)
> 2021-03-07T23:12:11.0844094Z at
> org.apache.flink.streaming.runtime.tasks.OperatorChain.closeOperators(OperatorChain.java:448)
> 2021-03-07T23:12:11.0845742Z at
> org.apache.flink.streaming.runtime.tasks.StreamTask.afterInvoke(StreamTask.java:634)
> 2021-03-07T23:12:11.0846700Z at
> org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:596)
> 2021-03-07T23:12:11.0847371Z at
> org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:760)
> 2021-03-07T23:12:11.0848283Z at
> org.apache.flink.runtime.taskmanager.Task.run(Task.java:562)
> 2021-03-07T23:12:11.0848777Z at java.lang.Thread.run(Thread.java:748)
> 2021-03-07T23:12:11.0849305Z Caused by: java.lang.RuntimeException: An error
> occurred in ElasticsearchSink.
> 2021-03-07T23:12:11.0850281Z at
> org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase.checkErrorAndRethrow(ElasticsearchSinkBase.java:427)
> 2021-03-07T23:12:11.0851165Z at
> org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase.close(ElasticsearchSinkBase.java:366)
> 2021-03-07T23:12:11.0852124Z at
> org.apache.flink.api.common.functions.util.FunctionUtils.closeFunction(FunctionUtils.java:41)
> 2021-03-07T23:12:11.0852935Z at
> org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.close(AbstractUdfStreamOperator.java:109)
> 2021-03-07T23:12:11.0853887Z at
> org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.lambda$closeOperator$5(StreamOperatorWrapper.java:213)
> 2021-03-07T23:12:11.0855067Z at
> org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$SynchronizedStreamTaskActionExecutor.runThrowing(StreamTaskActionExecutor.java:93)
> 2021-03-07T23:12:11.0856219Z at
> org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.closeOperator(StreamOperatorWrapper.java:210)
> 2021-03-07T23:12:11.0857301Z at
> org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.lambda$deferCloseOperatorToMailbox$3(StreamOperatorWrapper.java:185)
> 2021-03-07T23:12:11.0858612Z at
> org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$SynchronizedStreamTaskActionExecutor.runThrowing(StreamTaskActionExecutor.java:93)
> 2021-03-07T23:12:11.0859776Z at
> org.apache.flink.streaming.runtime.tasks.mailbox.Mail.run(Mail.java:90)
> 2021-03-07T23:12:11.0860656Z at
> org.apache.flink.streaming.runtime.tasks.mailbox.MailboxExecutorImpl.tryYield(MailboxExecutorImpl.java:97)
> 2021-03-07T23:12:11.0861681Z at
> org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.quiesceTimeServiceAndCloseOperator(StreamOperatorWrapper.java:162)
> 2021-03-07T23:12:11.0862392Z ... 10 more
> 2021-03-07T23:12:11.0862912Z Caused by: java.net.SocketTimeoutException
> 2021-03-07T23:12:11.0863538Z at
> org.apache.http.nio.protocol.HttpAsyncRequestExecutor.timeout(HttpAsyncRequestExecutor.java:375)
> 2021-03-07T23:12:11.0864518Z at
> org.apache.http.impl.nio.client.InternalIODispatch.onTimeout(InternalIODispatch.java:92)
> 2021-03-07T23:12:11.0865416Z at
> org.apache.http.impl.nio.client.InternalIODispatch.onTimeout(InternalIODispatch.java:39)
> 2021-03-07T23:12:11.0866190Z at
> org.apache.http.impl.nio.reactor.AbstractIODispatch.timeout(AbstractIODispatch.java:175)
> 2021-03-07T23:12:11.0866985Z at
> org.apache.http.impl.nio.reactor.BaseIOReactor.sessionTimedOut(BaseIOReactor.java:263)
> 2021-03-07T23:12:11.0868137Z at
> org.apache.http.impl.nio.reactor.AbstractIOReactor.timeoutCheck(AbstractIOReactor.java:492)
> 2021-03-07T23:12:11.0868902Z at
> org.apache.http.impl.nio.reactor.BaseIOReactor.validate(BaseIOReactor.java:213)
> 2021-03-07T23:12:11.0869785Z at
> org.apache.http.impl.nio.reactor.AbstractIOReactor.execute(AbstractIOReactor.java:280)
> 2021-03-07T23:12:11.0871097Z at
> org.apache.http.impl.nio.reactor.BaseIOReactor.execute(BaseIOReactor.java:104)
> 2021-03-07T23:12:11.0871967Z at
> org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor$Worker.run(AbstractMultiworkerIOReactor.java:588)
> 2021-03-07T23:12:11.0872551Z ... 1 more
> 2021-03-07T23:12:11.0872749Z
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
