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
Bug
Not a Priority