[FLINK-28177] Elasticsearch6DynamicSinkITCase.testWritingDocumentsNoPrimaryKey failed with 503 Service Unavailable - ASF JIRA

XML

Word

Printable

JSON

Details

Type: Bug
Status: Reopened
Priority: Critical
Resolution: Unresolved
Affects Version/s: 1.16.0
Fix Version/s: None
Component/s: Connectors / ElasticSearch
Labels:

Description

2022-06-21T07:39:23.9065585Z Jun 21 07:39:23 [ERROR] Tests run: 4, Failures: 0, Errors: 2, Skipped: 0, Time elapsed: 43.125 s <<< FAILURE! - in org.apache.flink.streaming.connectors.elasticsearch.table.Elasticsearch6DynamicSinkITCase
2022-06-21T07:39:23.9068457Z Jun 21 07:39:23 [ERROR] org.apache.flink.streaming.connectors.elasticsearch.table.Elasticsearch6DynamicSinkITCase.testWritingDocumentsNoPrimaryKey  Time elapsed: 8.697 s  <<< ERROR!
2022-06-21T07:39:23.9069955Z Jun 21 07:39:23 java.util.concurrent.ExecutionException: org.apache.flink.table.api.TableException: Failed to wait job finish
2022-06-21T07:39:23.9071135Z Jun 21 07:39:23 	at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357)
2022-06-21T07:39:23.9072225Z Jun 21 07:39:23 	at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1908)
2022-06-21T07:39:23.9073408Z Jun 21 07:39:23 	at org.apache.flink.table.api.internal.TableResultImpl.awaitInternal(TableResultImpl.java:118)
2022-06-21T07:39:23.9075081Z Jun 21 07:39:23 	at org.apache.flink.table.api.internal.TableResultImpl.await(TableResultImpl.java:81)
2022-06-21T07:39:23.9076560Z Jun 21 07:39:23 	at org.apache.flink.streaming.connectors.elasticsearch.table.Elasticsearch6DynamicSinkITCase.testWritingDocumentsNoPrimaryKey(Elasticsearch6DynamicSinkITCase.java:286)
2022-06-21T07:39:23.9078535Z Jun 21 07:39:23 	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
2022-06-21T07:39:23.9079534Z Jun 21 07:39:23 	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
2022-06-21T07:39:23.9080702Z Jun 21 07:39:23 	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2022-06-21T07:39:23.9081838Z Jun 21 07:39:23 	at java.lang.reflect.Method.invoke(Method.java:498)
2022-06-21T07:39:23.9082942Z Jun 21 07:39:23 	at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
2022-06-21T07:39:23.9084127Z Jun 21 07:39:23 	at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
2022-06-21T07:39:23.9085246Z Jun 21 07:39:23 	at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
2022-06-21T07:39:23.9086380Z Jun 21 07:39:23 	at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
2022-06-21T07:39:23.9087812Z Jun 21 07:39:23 	at org.apache.flink.util.TestNameProvider$1.evaluate(TestNameProvider.java:45)
2022-06-21T07:39:23.9088843Z Jun 21 07:39:23 	at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:61)
2022-06-21T07:39:23.9089823Z Jun 21 07:39:23 	at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
2022-06-21T07:39:23.9103797Z Jun 21 07:39:23 	at org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100)
2022-06-21T07:39:23.9105022Z Jun 21 07:39:23 	at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366)
2022-06-21T07:39:23.9106065Z Jun 21 07:39:23 	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103)
2022-06-21T07:39:23.9107500Z Jun 21 07:39:23 	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63)
2022-06-21T07:39:23.9108591Z Jun 21 07:39:23 	at org.junit.runners.ParentRunner$4.run(ParentRunner.java:331)
2022-06-21T07:39:23.9109575Z Jun 21 07:39:23 	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79)
2022-06-21T07:39:23.9110606Z Jun 21 07:39:23 	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329)
2022-06-21T07:39:23.9111634Z Jun 21 07:39:23 	at org.junit.runners.ParentRunner.access$100(ParentRunner.java:66)
2022-06-21T07:39:23.9112653Z Jun 21 07:39:23 	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293)
2022-06-21T07:39:23.9113922Z Jun 21 07:39:23 	at org.testcontainers.containers.FailureDetectingExternalResource$1.evaluate(FailureDetectingExternalResource.java:30)
2022-06-21T07:39:23.9115083Z Jun 21 07:39:23 	at org.junit.rules.RunRules.evaluate(RunRules.java:20)
2022-06-21T07:39:23.9116049Z Jun 21 07:39:23 	at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
2022-06-21T07:39:23.9117274Z Jun 21 07:39:23 	at org.junit.runners.ParentRunner.run(ParentRunner.java:413)
2022-06-21T07:39:23.9118325Z Jun 21 07:39:23 	at org.junit.runner.JUnitCore.run(JUnitCore.java:137)
2022-06-21T07:39:23.9119209Z Jun 21 07:39:23 	at org.junit.runner.JUnitCore.run(JUnitCore.java:115)
2022-06-21T07:39:23.9120252Z Jun 21 07:39:23 	at org.junit.vintage.engine.execution.RunnerExecutor.execute(RunnerExecutor.java:42)
2022-06-21T07:39:23.9121429Z Jun 21 07:39:23 	at org.junit.vintage.engine.VintageTestEngine.executeAllChildren(VintageTestEngine.java:80)
2022-06-21T07:39:23.9122551Z Jun 21 07:39:23 	at org.junit.vintage.engine.VintageTestEngine.execute(VintageTestEngine.java:72)
2022-06-21T07:39:23.9123804Z Jun 21 07:39:23 	at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:107)
2022-06-21T07:39:23.9125115Z Jun 21 07:39:23 	at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:88)
2022-06-21T07:39:23.9126752Z Jun 21 07:39:23 	at org.junit.platform.launcher.core.EngineExecutionOrchestrator.lambda$execute$0(EngineExecutionOrchestrator.java:54)
2022-06-21T07:39:23.9128514Z Jun 21 07:39:23 	at org.junit.platform.launcher.core.EngineExecutionOrchestrator.withInterceptedStreams(EngineExecutionOrchestrator.java:67)
2022-06-21T07:39:23.9130205Z Jun 21 07:39:23 	at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:52)
2022-06-21T07:39:23.9131495Z Jun 21 07:39:23 	at org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:114)
2022-06-21T07:39:23.9132711Z Jun 21 07:39:23 	at org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:86)
2022-06-21T07:39:23.9133994Z Jun 21 07:39:23 	at org.junit.platform.launcher.core.DefaultLauncherSession$DelegatingLauncher.execute(DefaultLauncherSession.java:86)
2022-06-21T07:39:23.9135312Z Jun 21 07:39:23 	at org.junit.platform.launcher.core.SessionPerRequestLauncher.execute(SessionPerRequestLauncher.java:53)
2022-06-21T07:39:23.9136669Z Jun 21 07:39:23 	at org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.execute(JUnitPlatformProvider.java:188)
2022-06-21T07:39:23.9138441Z Jun 21 07:39:23 	at org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invokeAllTests(JUnitPlatformProvider.java:154)
2022-06-21T07:39:23.9139779Z Jun 21 07:39:23 	at org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invoke(JUnitPlatformProvider.java:124)
2022-06-21T07:39:23.9141025Z Jun 21 07:39:23 	at org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:428)
2022-06-21T07:39:23.9142515Z Jun 21 07:39:23 	at org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:162)
2022-06-21T07:39:23.9143627Z Jun 21 07:39:23 	at org.apache.maven.surefire.booter.ForkedBooter.run(ForkedBooter.java:562)
2022-06-21T07:39:23.9144607Z Jun 21 07:39:23 	at org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:548)
2022-06-21T07:39:23.9145546Z Jun 21 07:39:23 Caused by: org.apache.flink.table.api.TableException: Failed to wait job finish
2022-06-21T07:39:23.9146964Z Jun 21 07:39:23 	at org.apache.flink.table.api.internal.InsertResultProvider.hasNext(InsertResultProvider.java:85)
2022-06-21T07:39:23.9148605Z Jun 21 07:39:23 	at org.apache.flink.table.api.internal.InsertResultProvider.isFirstRowReady(InsertResultProvider.java:71)
2022-06-21T07:39:23.9149875Z Jun 21 07:39:23 	at org.apache.flink.table.api.internal.TableResultImpl.lambda$awaitInternal$1(TableResultImpl.java:105)
2022-06-21T07:39:23.9151096Z Jun 21 07:39:23 	at java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1640)
2022-06-21T07:39:23.9152258Z Jun 21 07:39:23 	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
2022-06-21T07:39:23.9153435Z Jun 21 07:39:23 	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
2022-06-21T07:39:23.9154452Z Jun 21 07:39:23 	at java.lang.Thread.run(Thread.java:748)
2022-06-21T07:39:23.9155568Z Jun 21 07:39:23 Caused by: java.util.concurrent.ExecutionException: org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
2022-06-21T07:39:23.9156812Z Jun 21 07:39:23 	at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357)
2022-06-21T07:39:23.9158282Z Jun 21 07:39:23 	at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1908)
2022-06-21T07:39:23.9159528Z Jun 21 07:39:23 	at org.apache.flink.table.api.internal.InsertResultProvider.hasNext(InsertResultProvider.java:83)
2022-06-21T07:39:23.9160439Z Jun 21 07:39:23 	... 6 more
2022-06-21T07:39:23.9161272Z Jun 21 07:39:23 Caused by: org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
2022-06-21T07:39:23.9162423Z Jun 21 07:39:23 	at org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144)
2022-06-21T07:39:23.9163729Z Jun 21 07:39:23 	at org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$3(MiniClusterJobClient.java:141)
2022-06-21T07:39:23.9165328Z Jun 21 07:39:23 	at java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616)
2022-06-21T07:39:23.9166552Z Jun 21 07:39:23 	at java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591)
2022-06-21T07:39:23.9168323Z Jun 21 07:39:23 	at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
2022-06-21T07:39:23.9169486Z Jun 21 07:39:23 	at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
2022-06-21T07:39:23.9170692Z Jun 21 07:39:23 	at org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$1(AkkaInvocationHandler.java:268)
2022-06-21T07:39:23.9171919Z Jun 21 07:39:23 	at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
2022-06-21T07:39:23.9173149Z Jun 21 07:39:23 	at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
2022-06-21T07:39:23.9174422Z Jun 21 07:39:23 	at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
2022-06-21T07:39:23.9175566Z Jun 21 07:39:23 	at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
2022-06-21T07:39:23.9176814Z Jun 21 07:39:23 	at org.apache.flink.util.concurrent.FutureUtils.doForward(FutureUtils.java:1277)
2022-06-21T07:39:23.9178449Z Jun 21 07:39:23 	at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$null$1(ClassLoadingUtils.java:93)
2022-06-21T07:39:23.9179849Z Jun 21 07:39:23 	at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68)
2022-06-21T07:39:23.9181289Z Jun 21 07:39:23 	at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$guardCompletionWithContextClassLoader$2(ClassLoadingUtils.java:92)
2022-06-21T07:39:23.9182745Z Jun 21 07:39:23 	at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
2022-06-21T07:39:23.9184021Z Jun 21 07:39:23 	at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
2022-06-21T07:39:23.9185327Z Jun 21 07:39:23 	at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
2022-06-21T07:39:23.9186488Z Jun 21 07:39:23 	at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
2022-06-21T07:39:23.9188035Z Jun 21 07:39:23 	at org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$1.onComplete(AkkaFutureUtils.java:47)
2022-06-21T07:39:23.9189136Z Jun 21 07:39:23 	at akka.dispatch.OnComplete.internal(Future.scala:300)
2022-06-21T07:39:23.9189967Z Jun 21 07:39:23 	at akka.dispatch.OnComplete.internal(Future.scala:297)
2022-06-21T07:39:23.9190831Z Jun 21 07:39:23 	at akka.dispatch.japi$CallbackBridge.apply(Future.scala:224)
2022-06-21T07:39:23.9191735Z Jun 21 07:39:23 	at akka.dispatch.japi$CallbackBridge.apply(Future.scala:221)
2022-06-21T07:39:23.9192690Z Jun 21 07:39:23 	at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60)
2022-06-21T07:39:23.9193789Z Jun 21 07:39:23 	at org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$DirectExecutionContext.execute(AkkaFutureUtils.java:65)
2022-06-21T07:39:23.9194964Z Jun 21 07:39:23 	at scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:68)
2022-06-21T07:39:23.9196026Z Jun 21 07:39:23 	at scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1(Promise.scala:284)
2022-06-21T07:39:23.9197515Z Jun 21 07:39:23 	at scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1$adapted(Promise.scala:284)
2022-06-21T07:39:23.9198640Z Jun 21 07:39:23 	at scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:284)
2022-06-21T07:39:23.9199605Z Jun 21 07:39:23 	at akka.pattern.PromiseActorRef.$bang(AskSupport.scala:621)
2022-06-21T07:39:23.9200641Z Jun 21 07:39:23 	at akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:24)
2022-06-21T07:39:23.9201874Z Jun 21 07:39:23 	at akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:23)
2022-06-21T07:39:23.9203264Z Jun 21 07:39:23 	at scala.concurrent.Future.$anonfun$andThen$1(Future.scala:532)
2022-06-21T07:39:23.9204252Z Jun 21 07:39:23 	at scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:29)
2022-06-21T07:39:23.9205243Z Jun 21 07:39:23 	at scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:29)
2022-06-21T07:39:23.9206434Z Jun 21 07:39:23 	at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60)
2022-06-21T07:39:23.9207709Z Jun 21 07:39:23 	at akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:63)
2022-06-21T07:39:23.9208893Z Jun 21 07:39:23 	at akka.dispatch.BatchingExecutor$BlockableBatch.$anonfun$run$1(BatchingExecutor.scala:100)
2022-06-21T07:39:23.9209990Z Jun 21 07:39:23 	at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:12)
2022-06-21T07:39:23.9210973Z Jun 21 07:39:23 	at scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:81)
2022-06-21T07:39:23.9212039Z Jun 21 07:39:23 	at akka.dispatch.BatchingExecutor$BlockableBatch.run(BatchingExecutor.scala:100)
2022-06-21T07:39:23.9213096Z Jun 21 07:39:23 	at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:49)
2022-06-21T07:39:23.9214204Z Jun 21 07:39:23 	at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(ForkJoinExecutorConfigurator.scala:48)
2022-06-21T07:39:23.9215415Z Jun 21 07:39:23 	at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
2022-06-21T07:39:23.9216443Z Jun 21 07:39:23 	at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056)
2022-06-21T07:39:23.9217806Z Jun 21 07:39:23 	at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692)
2022-06-21T07:39:23.9218846Z Jun 21 07:39:23 	at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175)
2022-06-21T07:39:23.9219945Z Jun 21 07:39:23 Caused by: org.apache.flink.runtime.JobException: Recovery is suppressed by NoRestartBackoffTimeStrategy
2022-06-21T07:39:23.9221177Z Jun 21 07:39:23 	at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:138)
2022-06-21T07:39:23.9222644Z Jun 21 07:39:23 	at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:82)
2022-06-21T07:39:23.9223953Z Jun 21 07:39:23 	at org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:306)
2022-06-21T07:39:23.9225211Z Jun 21 07:39:23 	at org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:294)
2022-06-21T07:39:23.9226513Z Jun 21 07:39:23 	at org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:285)
2022-06-21T07:39:23.9228053Z Jun 21 07:39:23 	at org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:716)
2022-06-21T07:39:23.9229267Z Jun 21 07:39:23 	at org.apache.flink.runtime.scheduler.SchedulerNG.updateTaskExecutionState(SchedulerNG.java:78)
2022-06-21T07:39:23.9230414Z Jun 21 07:39:23 	at org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:443)
2022-06-21T07:39:23.9231443Z Jun 21 07:39:23 	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
2022-06-21T07:39:23.9232441Z Jun 21 07:39:23 	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
2022-06-21T07:39:23.9233528Z Jun 21 07:39:23 	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2022-06-21T07:39:23.9234547Z Jun 21 07:39:23 	at java.lang.reflect.Method.invoke(Method.java:498)
2022-06-21T07:39:23.9235592Z Jun 21 07:39:23 	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRpcInvocation$1(AkkaRpcActor.java:304)
2022-06-21T07:39:23.9236899Z Jun 21 07:39:23 	at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83)
2022-06-21T07:39:23.9238893Z Jun 21 07:39:23 	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:302)
2022-06-21T07:39:23.9240094Z Jun 21 07:39:23 	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:217)
2022-06-21T07:39:23.9241308Z Jun 21 07:39:23 	at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:77)
2022-06-21T07:39:23.9242831Z Jun 21 07:39:23 	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:163)
2022-06-21T07:39:23.9243901Z Jun 21 07:39:23 	at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24)
2022-06-21T07:39:23.9244861Z Jun 21 07:39:23 	at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20)
2022-06-21T07:39:23.9245873Z Jun 21 07:39:23 	at scala.PartialFunction.applyOrElse(PartialFunction.scala:123)
2022-06-21T07:39:23.9246814Z Jun 21 07:39:23 	at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122)
2022-06-21T07:39:23.9248051Z Jun 21 07:39:23 	at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20)
2022-06-21T07:39:23.9249032Z Jun 21 07:39:23 	at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
2022-06-21T07:39:23.9250006Z Jun 21 07:39:23 	at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
2022-06-21T07:39:23.9251054Z Jun 21 07:39:23 	at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
2022-06-21T07:39:23.9251981Z Jun 21 07:39:23 	at akka.actor.Actor.aroundReceive(Actor.scala:537)
2022-06-21T07:39:23.9252842Z Jun 21 07:39:23 	at akka.actor.Actor.aroundReceive$(Actor.scala:535)
2022-06-21T07:39:23.9253792Z Jun 21 07:39:23 	at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220)
2022-06-21T07:39:23.9254767Z Jun 21 07:39:23 	at akka.actor.ActorCell.receiveMessage(ActorCell.scala:580)
2022-06-21T07:39:23.9255671Z Jun 21 07:39:23 	at akka.actor.ActorCell.invoke(ActorCell.scala:548)
2022-06-21T07:39:23.9256575Z Jun 21 07:39:23 	at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270)
2022-06-21T07:39:23.9257800Z Jun 21 07:39:23 	at akka.dispatch.Mailbox.run(Mailbox.scala:231)
2022-06-21T07:39:23.9258656Z Jun 21 07:39:23 	at akka.dispatch.Mailbox.exec(Mailbox.scala:243)
2022-06-21T07:39:23.9259384Z Jun 21 07:39:23 	... 4 more
2022-06-21T07:39:23.9260945Z Jun 21 07:39:23 Caused by: org.elasticsearch.ElasticsearchStatusException: org.elasticsearch.ElasticsearchStatusException: method [HEAD], host [http://172.17.0.1:53246], URI [/], status line [HTTP/1.1 503 Service Unavailable]
2022-06-21T07:39:23.9262618Z Jun 21 07:39:23 	at org.elasticsearch.client.RestHighLevelClient.parseResponseException(RestHighLevelClient.java:2028)
2022-06-21T07:39:23.9263824Z Jun 21 07:39:23 	at org.elasticsearch.client.RestHighLevelClient.internalPerformRequest(RestHighLevelClient.java:1778)
2022-06-21T07:39:23.9265071Z Jun 21 07:39:23 	at org.elasticsearch.client.RestHighLevelClient.performRequest(RestHighLevelClient.java:1735)
2022-06-21T07:39:23.9266281Z Jun 21 07:39:23 	at org.elasticsearch.client.RestHighLevelClient.performRequest(RestHighLevelClient.java:1718)
2022-06-21T07:39:23.9267715Z Jun 21 07:39:23 	at org.elasticsearch.client.RestHighLevelClient.ping(RestHighLevelClient.java:705)
2022-06-21T07:39:23.9269055Z Jun 21 07:39:23 	at org.apache.flink.streaming.connectors.elasticsearch6.Elasticsearch6ApiCallBridge.verifyClientConnection(Elasticsearch6ApiCallBridge.java:140)
2022-06-21T07:39:23.9270666Z Jun 21 07:39:23 	at org.apache.flink.streaming.connectors.elasticsearch6.Elasticsearch6ApiCallBridge.verifyClientConnection(Elasticsearch6ApiCallBridge.java:45)
2022-06-21T07:39:23.9272139Z Jun 21 07:39:23 	at org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase.open(ElasticsearchSinkBase.java:317)
2022-06-21T07:39:23.9273433Z Jun 21 07:39:23 	at org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:34)
2022-06-21T07:39:23.9274713Z Jun 21 07:39:23 	at org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:100)
2022-06-21T07:39:23.9276289Z Jun 21 07:39:23 	at org.apache.flink.table.runtime.operators.sink.SinkOperator.open(SinkOperator.java:58)
2022-06-21T07:39:23.9277934Z Jun 21 07:39:23 	at org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.initializeStateAndOpenOperators(RegularOperatorChain.java:107)
2022-06-21T07:39:23.9279487Z Jun 21 07:39:23 	at org.apache.flink.streaming.runtime.tasks.StreamTask.restoreGates(StreamTask.java:722)
2022-06-21T07:39:23.9280891Z Jun 21 07:39:23 	at org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$SynchronizedStreamTaskActionExecutor.call(StreamTaskActionExecutor.java:100)
2022-06-21T07:39:23.9282338Z Jun 21 07:39:23 	at org.apache.flink.streaming.runtime.tasks.StreamTask.restoreInternal(StreamTask.java:698)
2022-06-21T07:39:23.9283489Z Jun 21 07:39:23 	at org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:665)
2022-06-21T07:39:23.9284539Z Jun 21 07:39:23 	at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:935)
2022-06-21T07:39:23.9285637Z Jun 21 07:39:23 	at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:904)
2022-06-21T07:39:23.9286658Z Jun 21 07:39:23 	at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:728)
2022-06-21T07:39:23.9287956Z Jun 21 07:39:23 	at org.apache.flink.runtime.taskmanager.Task.run(Task.java:550)
2022-06-21T07:39:23.9288874Z Jun 21 07:39:23 	at java.lang.Thread.run(Thread.java:748)
2022-06-21T07:39:23.9290431Z Jun 21 07:39:23 Caused by: org.elasticsearch.client.ResponseException: org.elasticsearch.client.ResponseException: method [HEAD], host [http://172.17.0.1:53246], URI [/], status line [HTTP/1.1 503 Service Unavailable]
2022-06-21T07:39:23.9292068Z Jun 21 07:39:23 	at org.elasticsearch.client.RestClient$SyncResponseListener.get(RestClient.java:936)
2022-06-21T07:39:23.9293173Z Jun 21 07:39:23 	at org.elasticsearch.client.RestClient.performRequest(RestClient.java:233)
2022-06-21T07:39:23.9294395Z Jun 21 07:39:23 	at org.elasticsearch.client.RestHighLevelClient.internalPerformRequest(RestHighLevelClient.java:1765)
2022-06-21T07:39:23.9295316Z Jun 21 07:39:23 	... 19 more
2022-06-21T07:39:23.9297237Z Jun 21 07:39:23 Caused by: org.elasticsearch.client.ResponseException: org.elasticsearch.client.ResponseException: method [HEAD], host [http://172.17.0.1:53246], URI [/], status line [HTTP/1.1 503 Service Unavailable]
2022-06-21T07:39:23.9298987Z Jun 21 07:39:23 	at org.elasticsearch.client.RestClient$1.completed(RestClient.java:552)
2022-06-21T07:39:23.9300097Z Jun 21 07:39:23 	at org.elasticsearch.client.RestClient$1.completed(RestClient.java:537)
2022-06-21T07:39:23.9301150Z Jun 21 07:39:23 	at org.apache.http.concurrent.BasicFuture.completed(BasicFuture.java:122)
2022-06-21T07:39:23.9302385Z Jun 21 07:39:23 	at org.apache.http.impl.nio.client.DefaultClientExchangeHandlerImpl.responseCompleted(DefaultClientExchangeHandlerImpl.java:177)
2022-06-21T07:39:23.9303793Z Jun 21 07:39:23 	at org.apache.http.nio.protocol.HttpAsyncRequestExecutor.processResponse(HttpAsyncRequestExecutor.java:436)
2022-06-21T07:39:23.9305195Z Jun 21 07:39:23 	at org.apache.http.nio.protocol.HttpAsyncRequestExecutor.responseReceived(HttpAsyncRequestExecutor.java:309)
2022-06-21T07:39:23.9306731Z Jun 21 07:39:23 	at org.apache.http.impl.nio.DefaultNHttpClientConnection.consumeInput(DefaultNHttpClientConnection.java:255)
2022-06-21T07:39:23.9308370Z Jun 21 07:39:23 	at org.apache.http.impl.nio.client.InternalIODispatch.onInputReady(InternalIODispatch.java:81)
2022-06-21T07:39:23.9309546Z Jun 21 07:39:23 	at org.apache.http.impl.nio.client.InternalIODispatch.onInputReady(InternalIODispatch.java:39)
2022-06-21T07:39:23.9310791Z Jun 21 07:39:23 	at org.apache.http.impl.nio.reactor.AbstractIODispatch.inputReady(AbstractIODispatch.java:114)
2022-06-21T07:39:23.9311965Z Jun 21 07:39:23 	at org.apache.http.impl.nio.reactor.BaseIOReactor.readable(BaseIOReactor.java:162)
2022-06-21T07:39:23.9313214Z Jun 21 07:39:23 	at org.apache.http.impl.nio.reactor.AbstractIOReactor.processEvent(AbstractIOReactor.java:337)
2022-06-21T07:39:23.9314834Z Jun 21 07:39:23 	at org.apache.http.impl.nio.reactor.AbstractIOReactor.processEvents(AbstractIOReactor.java:315)
2022-06-21T07:39:23.9316027Z Jun 21 07:39:23 	at org.apache.http.impl.nio.reactor.AbstractIOReactor.execute(AbstractIOReactor.java:276)
2022-06-21T07:39:23.9317681Z Jun 21 07:39:23 	at org.apache.http.impl.nio.reactor.BaseIOReactor.execute(BaseIOReactor.java:104)
2022-06-21T07:39:23.9318936Z Jun 21 07:39:23 	at org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor$Worker.run(AbstractMultiworkerIOReactor.java:588)
2022-06-21T07:39:23.9319925Z Jun 21 07:39:23 	... 1 more
2022-06-21T07:39:23.9320441Z Jun 21 07:39:23 
2022-06-21T07:39:23.9321427Z Jun 21 07:39:23 [ERROR] org.apache.flink.streaming.connectors.elasticsearch.table.Elasticsearch6DynamicSinkITCase.testWritingDocumentsFromTableApi  Time elapsed: 2.068 s  <<< ERROR!
2022-06-21T07:39:23.9322817Z Jun 21 07:39:23 java.util.concurrent.ExecutionException: org.apache.flink.table.api.TableException: Failed to wait job finish
2022-06-21T07:39:23.9323996Z Jun 21 07:39:23 	at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357)
2022-06-21T07:39:23.9325100Z Jun 21 07:39:23 	at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1908)
2022-06-21T07:39:23.9326175Z Jun 21 07:39:23 	at org.apache.flink.table.api.internal.TableResultImpl.awaitInternal(TableResultImpl.java:118)
2022-06-21T07:39:23.9327643Z Jun 21 07:39:23 	at org.apache.flink.table.api.internal.TableResultImpl.await(TableResultImpl.java:81)
2022-06-21T07:39:23.9328788Z Jun 21 07:39:23 	at org.apache.flink.streaming.connectors.elasticsearch.table.Elasticsearch6DynamicSinkITCase.testWritingDocumentsFromTableApi(Elasticsearch6DynamicSinkITCase.java:213)
2022-06-21T07:39:23.9329633Z Jun 21 07:39:23 	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
2022-06-21T07:39:23.9330267Z Jun 21 07:39:23 	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
2022-06-21T07:39:23.9330982Z Jun 21 07:39:23 	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2022-06-21T07:39:23.9331623Z Jun 21 07:39:23 	at java.lang.reflect.Method.invoke(Method.java:498)
2022-06-21T07:39:23.9332258Z Jun 21 07:39:23 	at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
2022-06-21T07:39:23.9332982Z Jun 21 07:39:23 	at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
2022-06-21T07:39:23.9333686Z Jun 21 07:39:23 	at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
2022-06-21T07:39:23.9334391Z Jun 21 07:39:23 	at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
2022-06-21T07:39:23.9335084Z Jun 21 07:39:23 	at org.apache.flink.util.TestNameProvider$1.evaluate(TestNameProvider.java:45)
2022-06-21T07:39:23.9335705Z Jun 21 07:39:23 	at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:61)
2022-06-21T07:39:23.9336325Z Jun 21 07:39:23 	at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
2022-06-21T07:39:23.9337002Z Jun 21 07:39:23 	at org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100)
2022-06-21T07:39:23.9337983Z Jun 21 07:39:23 	at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366)
2022-06-21T07:39:23.9338658Z Jun 21 07:39:23 	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103)
2022-06-21T07:39:23.9339367Z Jun 21 07:39:23 	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63)
2022-06-21T07:39:23.9339997Z Jun 21 07:39:23 	at org.junit.runners.ParentRunner$4.run(ParentRunner.java:331)
2022-06-21T07:39:23.9340618Z Jun 21 07:39:23 	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79)
2022-06-21T07:39:23.9341241Z Jun 21 07:39:23 	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329)
2022-06-21T07:39:23.9341874Z Jun 21 07:39:23 	at org.junit.runners.ParentRunner.access$100(ParentRunner.java:66)
2022-06-21T07:39:23.9342685Z Jun 21 07:39:23 	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293)
2022-06-21T07:39:23.9343430Z Jun 21 07:39:23 	at org.testcontainers.containers.FailureDetectingExternalResource$1.evaluate(FailureDetectingExternalResource.java:30)
2022-06-21T07:39:23.9344131Z Jun 21 07:39:23 	at org.junit.rules.RunRules.evaluate(RunRules.java:20)
2022-06-21T07:39:23.9344813Z Jun 21 07:39:23 	at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
2022-06-21T07:39:23.9345422Z Jun 21 07:39:23 	at org.junit.runners.ParentRunner.run(ParentRunner.java:413)
2022-06-21T07:39:23.9345994Z Jun 21 07:39:23 	at org.junit.runner.JUnitCore.run(JUnitCore.java:137)
2022-06-21T07:39:23.9346550Z Jun 21 07:39:23 	at org.junit.runner.JUnitCore.run(JUnitCore.java:115)
2022-06-21T07:39:23.9347265Z Jun 21 07:39:23 	at org.junit.vintage.engine.execution.RunnerExecutor.execute(RunnerExecutor.java:42)
2022-06-21T07:39:23.9348144Z Jun 21 07:39:23 	at org.junit.vintage.engine.VintageTestEngine.executeAllChildren(VintageTestEngine.java:80)
2022-06-21T07:39:23.9348866Z Jun 21 07:39:23 	at org.junit.vintage.engine.VintageTestEngine.execute(VintageTestEngine.java:72)
2022-06-21T07:39:23.9349622Z Jun 21 07:39:23 	at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:107)
2022-06-21T07:39:23.9350446Z Jun 21 07:39:23 	at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:88)
2022-06-21T07:39:23.9351290Z Jun 21 07:39:23 	at org.junit.platform.launcher.core.EngineExecutionOrchestrator.lambda$execute$0(EngineExecutionOrchestrator.java:54)
2022-06-21T07:39:23.9352164Z Jun 21 07:39:23 	at org.junit.platform.launcher.core.EngineExecutionOrchestrator.withInterceptedStreams(EngineExecutionOrchestrator.java:67)
2022-06-21T07:39:23.9353015Z Jun 21 07:39:23 	at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:52)
2022-06-21T07:39:23.9353789Z Jun 21 07:39:23 	at org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:114)
2022-06-21T07:39:23.9354473Z Jun 21 07:39:23 	at org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:86)
2022-06-21T07:39:23.9355264Z Jun 21 07:39:23 	at org.junit.platform.launcher.core.DefaultLauncherSession$DelegatingLauncher.execute(DefaultLauncherSession.java:86)
2022-06-21T07:39:23.9356105Z Jun 21 07:39:23 	at org.junit.platform.launcher.core.SessionPerRequestLauncher.execute(SessionPerRequestLauncher.java:53)
2022-06-21T07:39:23.9356904Z Jun 21 07:39:23 	at org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.execute(JUnitPlatformProvider.java:188)
2022-06-21T07:39:23.9357933Z Jun 21 07:39:23 	at org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invokeAllTests(JUnitPlatformProvider.java:154)
2022-06-21T07:39:23.9358752Z Jun 21 07:39:23 	at org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invoke(JUnitPlatformProvider.java:124)
2022-06-21T07:39:23.9359525Z Jun 21 07:39:23 	at org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:428)
2022-06-21T07:39:23.9360205Z Jun 21 07:39:23 	at org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:162)
2022-06-21T07:39:23.9360877Z Jun 21 07:39:23 	at org.apache.maven.surefire.booter.ForkedBooter.run(ForkedBooter.java:562)
2022-06-21T07:39:23.9361550Z Jun 21 07:39:23 	at org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:548)
2022-06-21T07:39:23.9362177Z Jun 21 07:39:23 Caused by: org.apache.flink.table.api.TableException: Failed to wait job finish
2022-06-21T07:39:23.9362855Z Jun 21 07:39:23 	at org.apache.flink.table.api.internal.InsertResultProvider.hasNext(InsertResultProvider.java:85)
2022-06-21T07:39:23.9363636Z Jun 21 07:39:23 	at org.apache.flink.table.api.internal.InsertResultProvider.isFirstRowReady(InsertResultProvider.java:71)
2022-06-21T07:39:23.9364426Z Jun 21 07:39:23 	at org.apache.flink.table.api.internal.TableResultImpl.lambda$awaitInternal$1(TableResultImpl.java:105)
2022-06-21T07:39:23.9365254Z Jun 21 07:39:23 	at java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1640)
2022-06-21T07:39:23.9365955Z Jun 21 07:39:23 	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
2022-06-21T07:39:23.9366651Z Jun 21 07:39:23 	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
2022-06-21T07:39:23.9367501Z Jun 21 07:39:23 	at java.lang.Thread.run(Thread.java:748)
2022-06-21T07:39:23.9368180Z Jun 21 07:39:23 Caused by: java.util.concurrent.ExecutionException: org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
2022-06-21T07:39:23.9368920Z Jun 21 07:39:23 	at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357)
2022-06-21T07:39:23.9369566Z Jun 21 07:39:23 	at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1908)
2022-06-21T07:39:23.9370273Z Jun 21 07:39:23 	at org.apache.flink.table.api.internal.InsertResultProvider.hasNext(InsertResultProvider.java:83)
2022-06-21T07:39:23.9370837Z Jun 21 07:39:23 	... 6 more
2022-06-21T07:39:23.9371324Z Jun 21 07:39:23 Caused by: org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
2022-06-21T07:39:23.9372011Z Jun 21 07:39:23 	at org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144)
2022-06-21T07:39:23.9372819Z Jun 21 07:39:23 	at org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$3(MiniClusterJobClient.java:141)
2022-06-21T07:39:23.9373600Z Jun 21 07:39:23 	at java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616)
2022-06-21T07:39:23.9374279Z Jun 21 07:39:23 	at java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591)
2022-06-21T07:39:23.9374996Z Jun 21 07:39:23 	at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
2022-06-21T07:39:23.9375690Z Jun 21 07:39:23 	at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
2022-06-21T07:39:23.9376451Z Jun 21 07:39:23 	at org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$1(AkkaInvocationHandler.java:268)
2022-06-21T07:39:23.9377293Z Jun 21 07:39:23 	at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
2022-06-21T07:39:23.9378273Z Jun 21 07:39:23 	at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
2022-06-21T07:39:23.9378979Z Jun 21 07:39:23 	at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
2022-06-21T07:39:23.9379668Z Jun 21 07:39:23 	at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
2022-06-21T07:39:23.9380348Z Jun 21 07:39:23 	at org.apache.flink.util.concurrent.FutureUtils.doForward(FutureUtils.java:1277)
2022-06-21T07:39:23.9381089Z Jun 21 07:39:23 	at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$null$1(ClassLoadingUtils.java:93)
2022-06-21T07:39:23.9381916Z Jun 21 07:39:23 	at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68)
2022-06-21T07:39:23.9382808Z Jun 21 07:39:23 	at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$guardCompletionWithContextClassLoader$2(ClassLoadingUtils.java:92)
2022-06-21T07:39:23.9383636Z Jun 21 07:39:23 	at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
2022-06-21T07:39:23.9384363Z Jun 21 07:39:23 	at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
2022-06-21T07:39:23.9385063Z Jun 21 07:39:23 	at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
2022-06-21T07:39:23.9385754Z Jun 21 07:39:23 	at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
2022-06-21T07:39:23.9386483Z Jun 21 07:39:23 	at org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$1.onComplete(AkkaFutureUtils.java:47)
2022-06-21T07:39:23.9387436Z Jun 21 07:39:23 	at akka.dispatch.OnComplete.internal(Future.scala:300)
2022-06-21T07:39:23.9388129Z Jun 21 07:39:23 	at akka.dispatch.OnComplete.internal(Future.scala:297)
2022-06-21T07:39:23.9388716Z Jun 21 07:39:23 	at akka.dispatch.japi$CallbackBridge.apply(Future.scala:224)
2022-06-21T07:39:23.9389296Z Jun 21 07:39:23 	at akka.dispatch.japi$CallbackBridge.apply(Future.scala:221)
2022-06-21T07:39:23.9389989Z Jun 21 07:39:23 	at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60)
2022-06-21T07:39:23.9390723Z Jun 21 07:39:23 	at org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$DirectExecutionContext.execute(AkkaFutureUtils.java:65)
2022-06-21T07:39:23.9391482Z Jun 21 07:39:23 	at scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:68)
2022-06-21T07:39:23.9392184Z Jun 21 07:39:23 	at scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1(Promise.scala:284)
2022-06-21T07:39:23.9392935Z Jun 21 07:39:23 	at scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1$adapted(Promise.scala:284)
2022-06-21T07:39:23.9393646Z Jun 21 07:39:23 	at scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:284)
2022-06-21T07:39:23.9394287Z Jun 21 07:39:23 	at akka.pattern.PromiseActorRef.$bang(AskSupport.scala:621)
2022-06-21T07:39:23.9394967Z Jun 21 07:39:23 	at akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:24)
2022-06-21T07:39:23.9395747Z Jun 21 07:39:23 	at akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:23)
2022-06-21T07:39:23.9396439Z Jun 21 07:39:23 	at scala.concurrent.Future.$anonfun$andThen$1(Future.scala:532)
2022-06-21T07:39:23.9397162Z Jun 21 07:39:23 	at scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:29)
2022-06-21T07:39:23.9398011Z Jun 21 07:39:23 	at scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:29)
2022-06-21T07:39:23.9398628Z Jun 21 07:39:23 	at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60)
2022-06-21T07:39:23.9399299Z Jun 21 07:39:23 	at akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:63)
2022-06-21T07:39:23.9400043Z Jun 21 07:39:23 	at akka.dispatch.BatchingExecutor$BlockableBatch.$anonfun$run$1(BatchingExecutor.scala:100)
2022-06-21T07:39:23.9400745Z Jun 21 07:39:23 	at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:12)
2022-06-21T07:39:23.9401407Z Jun 21 07:39:23 	at scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:81)
2022-06-21T07:39:23.9402080Z Jun 21 07:39:23 	at akka.dispatch.BatchingExecutor$BlockableBatch.run(BatchingExecutor.scala:100)
2022-06-21T07:39:23.9402715Z Jun 21 07:39:23 	at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:49)
2022-06-21T07:39:23.9403433Z Jun 21 07:39:23 	at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(ForkJoinExecutorConfigurator.scala:48)
2022-06-21T07:39:23.9404146Z Jun 21 07:39:23 	at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
2022-06-21T07:39:23.9404799Z Jun 21 07:39:23 	at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056)
2022-06-21T07:39:23.9405447Z Jun 21 07:39:23 	at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692)
2022-06-21T07:39:23.9406113Z Jun 21 07:39:23 	at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175)
2022-06-21T07:39:23.9406808Z Jun 21 07:39:23 Caused by: org.apache.flink.runtime.JobException: Recovery is suppressed by NoRestartBackoffTimeStrategy
2022-06-21T07:39:23.9407872Z Jun 21 07:39:23 	at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:138)
2022-06-21T07:39:23.9408835Z Jun 21 07:39:23 	at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:82)
2022-06-21T07:39:23.9409707Z Jun 21 07:39:23 	at org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:306)
2022-06-21T07:39:23.9410617Z Jun 21 07:39:23 	at org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:294)
2022-06-21T07:39:23.9411435Z Jun 21 07:39:23 	at org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:285)
2022-06-21T07:39:23.9412265Z Jun 21 07:39:23 	at org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:716)
2022-06-21T07:39:23.9413123Z Jun 21 07:39:23 	at org.apache.flink.runtime.scheduler.SchedulerNG.updateTaskExecutionState(SchedulerNG.java:78)
2022-06-21T07:39:23.9413868Z Jun 21 07:39:23 	at org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:443)
2022-06-21T07:39:23.9414521Z Jun 21 07:39:23 	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
2022-06-21T07:39:23.9415144Z Jun 21 07:39:23 	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
2022-06-21T07:39:23.9415860Z Jun 21 07:39:23 	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2022-06-21T07:39:23.9416508Z Jun 21 07:39:23 	at java.lang.reflect.Method.invoke(Method.java:498)
2022-06-21T07:39:23.9417257Z Jun 21 07:39:23 	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRpcInvocation$1(AkkaRpcActor.java:304)
2022-06-21T07:39:23.9418395Z Jun 21 07:39:23 	at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83)
2022-06-21T07:39:23.9419186Z Jun 21 07:39:23 	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:302)
2022-06-21T07:39:23.9419935Z Jun 21 07:39:23 	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:217)
2022-06-21T07:39:23.9420695Z Jun 21 07:39:23 	at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:77)
2022-06-21T07:39:23.9421445Z Jun 21 07:39:23 	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:163)
2022-06-21T07:39:23.9422116Z Jun 21 07:39:23 	at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24)
2022-06-21T07:39:23.9422738Z Jun 21 07:39:23 	at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20)
2022-06-21T07:39:23.9423333Z Jun 21 07:39:23 	at scala.PartialFunction.applyOrElse(PartialFunction.scala:123)
2022-06-21T07:39:23.9423947Z Jun 21 07:39:23 	at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122)
2022-06-21T07:39:23.9424575Z Jun 21 07:39:23 	at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20)
2022-06-21T07:39:23.9425216Z Jun 21 07:39:23 	at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
2022-06-21T07:39:23.9425853Z Jun 21 07:39:23 	at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
2022-06-21T07:39:23.9426495Z Jun 21 07:39:23 	at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
2022-06-21T07:39:23.9427148Z Jun 21 07:39:23 	at akka.actor.Actor.aroundReceive(Actor.scala:537)
2022-06-21T07:39:23.9427891Z Jun 21 07:39:23 	at akka.actor.Actor.aroundReceive$(Actor.scala:535)
2022-06-21T07:39:23.9428487Z Jun 21 07:39:23 	at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220)
2022-06-21T07:39:23.9429094Z Jun 21 07:39:23 	at akka.actor.ActorCell.receiveMessage(ActorCell.scala:580)
2022-06-21T07:39:23.9429662Z Jun 21 07:39:23 	at akka.actor.ActorCell.invoke(ActorCell.scala:548)
2022-06-21T07:39:23.9430242Z Jun 21 07:39:23 	at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270)
2022-06-21T07:39:23.9430784Z Jun 21 07:39:23 	at akka.dispatch.Mailbox.run(Mailbox.scala:231)
2022-06-21T07:39:23.9431319Z Jun 21 07:39:23 	at akka.dispatch.Mailbox.exec(Mailbox.scala:243)
2022-06-21T07:39:23.9431758Z Jun 21 07:39:23 	... 4 more
2022-06-21T07:39:23.9432524Z Jun 21 07:39:23 Caused by: org.elasticsearch.ElasticsearchStatusException: org.elasticsearch.ElasticsearchStatusException: method [HEAD], host [http://172.17.0.1:53246], URI [/], status line [HTTP/1.1 503 Service Unavailable]
2022-06-21T07:39:23.9433670Z Jun 21 07:39:23 	at org.elasticsearch.client.RestHighLevelClient.parseResponseException(RestHighLevelClient.java:2028)
2022-06-21T07:39:23.9434456Z Jun 21 07:39:23 	at org.elasticsearch.client.RestHighLevelClient.internalPerformRequest(RestHighLevelClient.java:1778)
2022-06-21T07:39:23.9435218Z Jun 21 07:39:23 	at org.elasticsearch.client.RestHighLevelClient.performRequest(RestHighLevelClient.java:1735)
2022-06-21T07:39:23.9436068Z Jun 21 07:39:23 	at org.elasticsearch.client.RestHighLevelClient.performRequest(RestHighLevelClient.java:1718)
2022-06-21T07:39:23.9436792Z Jun 21 07:39:23 	at org.elasticsearch.client.RestHighLevelClient.ping(RestHighLevelClient.java:705)
2022-06-21T07:39:23.9437916Z Jun 21 07:39:23 	at org.apache.flink.streaming.connectors.elasticsearch6.Elasticsearch6ApiCallBridge.verifyClientConnection(Elasticsearch6ApiCallBridge.java:140)
2022-06-21T07:39:23.9438928Z Jun 21 07:39:23 	at org.apache.flink.streaming.connectors.elasticsearch6.Elasticsearch6ApiCallBridge.verifyClientConnection(Elasticsearch6ApiCallBridge.java:45)
2022-06-21T07:39:23.9439860Z Jun 21 07:39:23 	at org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase.open(ElasticsearchSinkBase.java:317)
2022-06-21T07:39:23.9440663Z Jun 21 07:39:23 	at org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:34)
2022-06-21T07:39:23.9441468Z Jun 21 07:39:23 	at org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:100)
2022-06-21T07:39:23.9442246Z Jun 21 07:39:23 	at org.apache.flink.table.runtime.operators.sink.SinkOperator.open(SinkOperator.java:58)
2022-06-21T07:39:23.9443048Z Jun 21 07:39:23 	at org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.initializeStateAndOpenOperators(RegularOperatorChain.java:107)
2022-06-21T07:39:23.9443869Z Jun 21 07:39:23 	at org.apache.flink.streaming.runtime.tasks.StreamTask.restoreGates(StreamTask.java:722)
2022-06-21T07:39:23.9444733Z Jun 21 07:39:23 	at org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$SynchronizedStreamTaskActionExecutor.call(StreamTaskActionExecutor.java:100)
2022-06-21T07:39:23.9445604Z Jun 21 07:39:23 	at org.apache.flink.streaming.runtime.tasks.StreamTask.restoreInternal(StreamTask.java:698)
2022-06-21T07:39:23.9446320Z Jun 21 07:39:23 	at org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:665)
2022-06-21T07:39:23.9447276Z Jun 21 07:39:23 	at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:935)
2022-06-21T07:39:23.9448183Z Jun 21 07:39:23 	at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:904)
2022-06-21T07:39:23.9448814Z Jun 21 07:39:23 	at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:728)
2022-06-21T07:39:23.9449428Z Jun 21 07:39:23 	at org.apache.flink.runtime.taskmanager.Task.run(Task.java:550)
2022-06-21T07:39:23.9449984Z Jun 21 07:39:23 	at java.lang.Thread.run(Thread.java:748)
2022-06-21T07:39:23.9450789Z Jun 21 07:39:23 Caused by: org.elasticsearch.client.ResponseException: org.elasticsearch.client.ResponseException: method [HEAD], host [http://172.17.0.1:53246], URI [/], status line [HTTP/1.1 503 Service Unavailable]
2022-06-21T07:39:23.9451698Z Jun 21 07:39:23 	at org.elasticsearch.client.RestClient$SyncResponseListener.get(RestClient.java:936)
2022-06-21T07:39:23.9452379Z Jun 21 07:39:23 	at org.elasticsearch.client.RestClient.performRequest(RestClient.java:233)
2022-06-21T07:39:23.9453102Z Jun 21 07:39:23 	at org.elasticsearch.client.RestHighLevelClient.internalPerformRequest(RestHighLevelClient.java:1765)
2022-06-21T07:39:23.9453647Z Jun 21 07:39:23 	... 19 more
2022-06-21T07:39:23.9454367Z Jun 21 07:39:23 Caused by: org.elasticsearch.client.ResponseException: org.elasticsearch.client.ResponseException: method [HEAD], host [http://172.17.0.1:53246], URI [/], status line [HTTP/1.1 503 Service Unavailable]
2022-06-21T07:39:23.9455236Z Jun 21 07:39:23 	at org.elasticsearch.client.RestClient$1.completed(RestClient.java:552)
2022-06-21T07:39:23.9456024Z Jun 21 07:39:23 	at org.elasticsearch.client.RestClient$1.completed(RestClient.java:537)
2022-06-21T07:39:23.9456672Z Jun 21 07:39:23 	at org.apache.http.concurrent.BasicFuture.completed(BasicFuture.java:122)
2022-06-21T07:39:23.9457735Z Jun 21 07:39:23 	at org.apache.http.impl.nio.client.DefaultClientExchangeHandlerImpl.responseCompleted(DefaultClientExchangeHandlerImpl.java:177)
2022-06-21T07:39:23.9458724Z Jun 21 07:39:23 	at org.apache.http.nio.protocol.HttpAsyncRequestExecutor.processResponse(HttpAsyncRequestExecutor.java:436)
2022-06-21T07:39:23.9459529Z Jun 21 07:39:23 	at org.apache.http.nio.protocol.HttpAsyncRequestExecutor.responseReceived(HttpAsyncRequestExecutor.java:309)
2022-06-21T07:39:23.9460352Z Jun 21 07:39:23 	at org.apache.http.impl.nio.DefaultNHttpClientConnection.consumeInput(DefaultNHttpClientConnection.java:255)
2022-06-21T07:39:23.9461146Z Jun 21 07:39:23 	at org.apache.http.impl.nio.client.InternalIODispatch.onInputReady(InternalIODispatch.java:81)
2022-06-21T07:39:23.9461905Z Jun 21 07:39:23 	at org.apache.http.impl.nio.client.InternalIODispatch.onInputReady(InternalIODispatch.java:39)
2022-06-21T07:39:23.9462666Z Jun 21 07:39:23 	at org.apache.http.impl.nio.reactor.AbstractIODispatch.inputReady(AbstractIODispatch.java:114)
2022-06-21T07:39:23.9463399Z Jun 21 07:39:23 	at org.apache.http.impl.nio.reactor.BaseIOReactor.readable(BaseIOReactor.java:162)
2022-06-21T07:39:23.9464132Z Jun 21 07:39:23 	at org.apache.http.impl.nio.reactor.AbstractIOReactor.processEvent(AbstractIOReactor.java:337)
2022-06-21T07:39:23.9464872Z Jun 21 07:39:23 	at org.apache.http.impl.nio.reactor.AbstractIOReactor.processEvents(AbstractIOReactor.java:315)
2022-06-21T07:39:23.9465617Z Jun 21 07:39:23 	at org.apache.http.impl.nio.reactor.AbstractIOReactor.execute(AbstractIOReactor.java:276)
2022-06-21T07:39:23.9466324Z Jun 21 07:39:23 	at org.apache.http.impl.nio.reactor.BaseIOReactor.execute(BaseIOReactor.java:104)
2022-06-21T07:39:23.9467164Z Jun 21 07:39:23 	at org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor$Worker.run(AbstractMultiworkerIOReactor.java:588)
2022-06-21T07:39:23.9467977Z Jun 21 07:39:23 	... 1 more