[
https://issues.apache.org/jira/browse/FLINK-28177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17650352#comment-17650352
]
Martijn Visser commented on FLINK-28177:
----------------------------------------
Fixed in flink-connector-elasticsearch: 79e7c96666c3518777a3914a7902764d98b038e7
[~mapohl] Do you think it should also be backported to 1.16? Given that
Elasticsearch isn't in 1.17 anymore and these issues aren't regularly
occurring, I'm leaning towards closing the ticket and only for it in the
externalized version. WDYT?
> Elasticsearch6DynamicSinkITCase.testWritingDocumentsNoPrimaryKey failed with
> 503 Service Unavailable
> ----------------------------------------------------------------------------------------------------
>
> Key: FLINK-28177
> URL: https://issues.apache.org/jira/browse/FLINK-28177
> Project: Flink
> Issue Type: Bug
> Components: Connectors / ElasticSearch
> Affects Versions: 1.16.0
> Reporter: Huang Xingbo
> Assignee: KurtDing
> Priority: Critical
> Labels: pull-request-available, stale-assigned, test-stability
> Fix For: 1.16.0, elasticsearch-4.0.0
>
> Attachments: image-2022-07-21-10-48-33-213.png
>
>
> {code:java}
> 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
> {code}
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=36994&view=logs&j=4eda0b4a-bd0d-521a-0916-8285b9be9bb5&t=2ff6d5fa-53a6-53ac-bff7-fa524ea361a9
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
