Matthias Pohl created FLINK-31168:
-------------------------------------
Summary: JobManagerHAProcessFailureRecoveryITCase failed due to
job not being found
Key: FLINK-31168
URL: https://issues.apache.org/jira/browse/FLINK-31168
Project: Flink
Issue Type: Bug
Components: Runtime / Coordination
Affects Versions: 1.15.3
Reporter: Matthias Pohl
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=46342&view=logs&j=b0a398c0-685b-599c-eb57-c8c2a771138e&t=747432ad-a576-5911-1e2a-68c6bedc248a&l=12706
We see this build failure because a job couldn't be found:
{code}
2023-02-21T02:55:31.2739440Z java.lang.RuntimeException:
java.util.concurrent.ExecutionException: java.lang.RuntimeException: Error
while waiting for job to be initialized
2023-02-21T02:55:31.2741768Z at
org.apache.flink.util.ExceptionUtils.rethrow(ExceptionUtils.java:319)
2023-02-21T02:55:31.2742818Z at
org.apache.flink.api.java.ExecutionEnvironment.executeAsync(ExecutionEnvironment.java:1061)
2023-02-21T02:55:31.2743733Z at
org.apache.flink.api.java.ExecutionEnvironment.execute(ExecutionEnvironment.java:958)
2023-02-21T02:55:31.2744521Z at
org.apache.flink.api.java.ExecutionEnvironment.execute(ExecutionEnvironment.java:942)
2023-02-21T02:55:31.2745563Z at
org.apache.flink.test.recovery.JobManagerHAProcessFailureRecoveryITCase.testJobManagerFailure(JobManagerHAProcessFailureRecoveryITCase.java:235)
2023-02-21T02:55:31.2751144Z at
org.apache.flink.test.recovery.JobManagerHAProcessFailureRecoveryITCase$4.run(JobManagerHAProcessFailureRecoveryITCase.java:336)
2023-02-21T02:55:31.2752388Z Caused by:
java.util.concurrent.ExecutionException: java.lang.RuntimeException: Error
while waiting for job to be initialized
2023-02-21T02:55:31.2753289Z at
java.base/java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:395)
2023-02-21T02:55:31.2754081Z at
java.base/java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1999)
2023-02-21T02:55:31.2754759Z at
org.apache.flink.api.java.ExecutionEnvironment.executeAsync(ExecutionEnvironment.java:1056)
2023-02-21T02:55:31.2755241Z ... 4 more
2023-02-21T02:55:31.2755787Z Caused by: java.lang.RuntimeException: Error while
waiting for job to be initialized
2023-02-21T02:55:31.2756673Z at
org.apache.flink.client.ClientUtils.waitUntilJobInitializationFinished(ClientUtils.java:160)
2023-02-21T02:55:31.2757958Z at
org.apache.flink.client.deployment.executors.AbstractSessionClusterExecutor.lambda$execute$2(AbstractSessionClusterExecutor.java:82)
2023-02-21T02:55:31.2758777Z at
org.apache.flink.util.function.FunctionUtils.lambda$uncheckedFunction$2(FunctionUtils.java:73)
2023-02-21T02:55:31.2759520Z at
java.base/java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:642)
2023-02-21T02:55:31.2760203Z at
java.base/java.util.concurrent.CompletableFuture$Completion.exec(CompletableFuture.java:479)
2023-02-21T02:55:31.2760844Z at
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
2023-02-21T02:55:31.2761483Z at
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
2023-02-21T02:55:31.2762094Z at
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
2023-02-21T02:55:31.2762687Z at
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
2023-02-21T02:55:31.2763314Z at
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
2023-02-21T02:55:31.2764158Z Caused by:
java.util.concurrent.ExecutionException:
org.apache.flink.runtime.rest.util.RestClientException:
[org.apache.flink.runtime.rest.NotFoundException: Job
865dcd87f4828dbeb3d93eb52e2636b1 not found
2023-02-21T02:55:31.2765129Z at
org.apache.flink.runtime.rest.handler.job.AbstractExecutionGraphHandler.lambda$handleRequest$1(AbstractExecutionGraphHandler.java:99)
2023-02-21T02:55:31.2765993Z at
java.base/java.util.concurrent.CompletableFuture.uniExceptionally(CompletableFuture.java:986)
2023-02-21T02:55:31.2766699Z at
java.base/java.util.concurrent.CompletableFuture$UniExceptionally.tryFire(CompletableFuture.java:970)
2023-02-21T02:55:31.2767578Z at
java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506)
2023-02-21T02:55:31.2768398Z at
java.base/java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:2088)
2023-02-21T02:55:31.2769267Z at
org.apache.flink.runtime.rest.handler.legacy.DefaultExecutionGraphCache.lambda$getExecutionGraphInternal$0(DefaultExecutionGraphCache.java:109)
2023-02-21T02:55:31.2770090Z at
java.base/java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:859)
2023-02-21T02:55:31.2770781Z at
java.base/java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:837)
2023-02-21T02:55:31.2771512Z at
java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506)
2023-02-21T02:55:31.2773120Z at
java.base/java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:2088)
2023-02-21T02:55:31.2774116Z at
org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$1(AkkaInvocationHandler.java:252)
2023-02-21T02:55:31.2775177Z at
java.base/java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:859)
2023-02-21T02:55:31.2775980Z at
java.base/java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:837)
2023-02-21T02:55:31.2777045Z at
java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506)
2023-02-21T02:55:31.2778258Z at
java.base/java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:2088)
2023-02-21T02:55:31.2779045Z at
org.apache.flink.util.concurrent.FutureUtils.doForward(FutureUtils.java:1387)
2023-02-21T02:55:31.2780197Z at
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$guardCompletionWithContextClassLoader$1(ClassLoadingUtils.java:93)
2023-02-21T02:55:31.2781203Z at
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68)
2023-02-21T02:55:31.2782048Z at
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$guardCompletionWithContextClassLoader$2(ClassLoadingUtils.java:92)
2023-02-21T02:55:31.2783052Z at
java.base/java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:859)
2023-02-21T02:55:31.2784190Z at
java.base/java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:837)
2023-02-21T02:55:31.2785152Z at
java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506)
2023-02-21T02:55:31.2786018Z at
java.base/java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:2088)
2023-02-21T02:55:31.2787072Z at
org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$1.onComplete(AkkaFutureUtils.java:45)
2023-02-21T02:55:31.2788266Z at
akka.dispatch.OnComplete.internal(Future.scala:299)
2023-02-21T02:55:31.2789155Z at
akka.dispatch.OnComplete.internal(Future.scala:297)
2023-02-21T02:55:31.2789702Z at
akka.dispatch.japi$CallbackBridge.apply(Future.scala:224)
2023-02-21T02:55:31.2790258Z at
akka.dispatch.japi$CallbackBridge.apply(Future.scala:221)
2023-02-21T02:55:31.2791182Z at
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60)
2023-02-21T02:55:31.2792187Z at
org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$DirectExecutionContext.execute(AkkaFutureUtils.java:65)
2023-02-21T02:55:31.2793428Z at
scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:68)
2023-02-21T02:55:31.2794562Z at
scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1(Promise.scala:284)
2023-02-21T02:55:31.2795638Z at
scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1$adapted(Promise.scala:284)
2023-02-21T02:55:31.2796316Z at
scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:284)
2023-02-21T02:55:31.2796896Z at
akka.pattern.PromiseActorRef.$bang(AskSupport.scala:621)
2023-02-21T02:55:31.2797951Z at
akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:25)
2023-02-21T02:55:31.2798953Z at
akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:23)
2023-02-21T02:55:31.2799587Z at
scala.concurrent.Future.$anonfun$andThen$1(Future.scala:532)
2023-02-21T02:55:31.2800138Z at
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:29)
2023-02-21T02:55:31.2800792Z at
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:29)
2023-02-21T02:55:31.2801437Z at
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60)
2023-02-21T02:55:31.2802394Z at
akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:63)
2023-02-21T02:55:31.2803224Z at
akka.dispatch.BatchingExecutor$BlockableBatch.$anonfun$run$1(BatchingExecutor.scala:100)
2023-02-21T02:55:31.2804546Z at
scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:12)
2023-02-21T02:55:31.2805573Z at
scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:81)
2023-02-21T02:55:31.2806202Z at
akka.dispatch.BatchingExecutor$BlockableBatch.run(BatchingExecutor.scala:100)
2023-02-21T02:55:31.2807336Z at
akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:49)
2023-02-21T02:55:31.2808494Z at
akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(ForkJoinExecutorConfigurator.scala:48)
2023-02-21T02:55:31.2809548Z at
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
2023-02-21T02:55:31.2810206Z at
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
2023-02-21T02:55:31.2810984Z at
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
2023-02-21T02:55:31.2811659Z at
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
2023-02-21T02:55:31.2812391Z at
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
2023-02-21T02:55:31.2813491Z Caused by:
org.apache.flink.runtime.messages.FlinkJobNotFoundException: Could not find
Flink job (865dcd87f4828dbeb3d93eb52e2636b1)
2023-02-21T02:55:31.2814521Z at
org.apache.flink.runtime.dispatcher.Dispatcher.requestExecutionGraphInfo(Dispatcher.java:840)
2023-02-21T02:55:31.2815181Z at
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
2023-02-21T02:55:31.2815879Z at
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
2023-02-21T02:55:31.2816876Z at
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2023-02-21T02:55:31.2817956Z at
java.base/java.lang.reflect.Method.invoke(Method.java:566)
2023-02-21T02:55:31.2818832Z at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRpcInvocation$1(AkkaRpcActor.java:304)
2023-02-21T02:55:31.2819806Z at
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83)
2023-02-21T02:55:31.2820666Z at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:302)
2023-02-21T02:55:31.2821358Z at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:217)
2023-02-21T02:55:31.2822065Z at
org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:78)
2023-02-21T02:55:31.2822766Z at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:163)
2023-02-21T02:55:31.2823529Z at
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24)
2023-02-21T02:55:31.2824190Z at
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20)
2023-02-21T02:55:31.2824851Z at
scala.PartialFunction.applyOrElse(PartialFunction.scala:123)
2023-02-21T02:55:31.2825420Z at
scala.PartialFunction.applyOrElse$(PartialFunction.scala:122)
2023-02-21T02:55:31.2826087Z at
akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20)
2023-02-21T02:55:31.2826674Z at
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
2023-02-21T02:55:31.2827473Z at
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
2023-02-21T02:55:31.2828228Z at
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
2023-02-21T02:55:31.2828776Z at
akka.actor.Actor.aroundReceive(Actor.scala:537)
2023-02-21T02:55:31.2829344Z at
akka.actor.Actor.aroundReceive$(Actor.scala:535)
2023-02-21T02:55:31.2830120Z at
akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220)
2023-02-21T02:55:31.2830890Z at
akka.actor.ActorCell.receiveMessage(ActorCell.scala:580)
2023-02-21T02:55:31.2831743Z at
akka.actor.ActorCell.invoke(ActorCell.scala:548)
2023-02-21T02:55:31.2832590Z at
akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270)
2023-02-21T02:55:31.2833466Z at akka.dispatch.Mailbox.run(Mailbox.scala:231)
2023-02-21T02:55:31.2834334Z at akka.dispatch.Mailbox.exec(Mailbox.scala:243)
2023-02-21T02:55:31.2834942Z ... 5 more
2023-02-21T02:55:31.2835359Z ]
2023-02-21T02:55:31.2836169Z at
java.base/java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:395)
2023-02-21T02:55:31.2836817Z at
java.base/java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1999)
2023-02-21T02:55:31.2838283Z at
org.apache.flink.client.deployment.executors.AbstractSessionClusterExecutor.lambda$execute$0(AbstractSessionClusterExecutor.java:83)
2023-02-21T02:55:31.2839100Z at
org.apache.flink.client.ClientUtils.waitUntilJobInitializationFinished(ClientUtils.java:144)
2023-02-21T02:55:31.2839585Z ... 9 more
2023-02-21T02:55:31.2840148Z Caused by:
org.apache.flink.runtime.rest.util.RestClientException:
[org.apache.flink.runtime.rest.NotFoundException: Job
865dcd87f4828dbeb3d93eb52e2636b1 not found
2023-02-21T02:55:31.2841044Z at
org.apache.flink.runtime.rest.handler.job.AbstractExecutionGraphHandler.lambda$handleRequest$1(AbstractExecutionGraphHandler.java:99)
2023-02-21T02:55:31.2841848Z at
java.base/java.util.concurrent.CompletableFuture.uniExceptionally(CompletableFuture.java:986)
2023-02-21T02:55:31.2842550Z at
java.base/java.util.concurrent.CompletableFuture$UniExceptionally.tryFire(CompletableFuture.java:970)
2023-02-21T02:55:31.2843389Z at
java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506)
2023-02-21T02:55:31.2844119Z at
java.base/java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:2088)
2023-02-21T02:55:31.2844953Z at
org.apache.flink.runtime.rest.handler.legacy.DefaultExecutionGraphCache.lambda$getExecutionGraphInternal$0(DefaultExecutionGraphCache.java:109)
2023-02-21T02:55:31.2845842Z at
java.base/java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:859)
2023-02-21T02:55:31.2846526Z at
java.base/java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:837)
2023-02-21T02:55:31.2847413Z at
java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506)
2023-02-21T02:55:31.2848407Z at
java.base/java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:2088)
2023-02-21T02:55:31.2849165Z at
org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$1(AkkaInvocationHandler.java:252)
2023-02-21T02:55:31.2849885Z at
java.base/java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:859)
2023-02-21T02:55:31.2850584Z at
java.base/java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:837)
2023-02-21T02:55:31.2851257Z at
java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506)
2023-02-21T02:55:31.2851946Z at
java.base/java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:2088)
2023-02-21T02:55:31.2852606Z at
org.apache.flink.util.concurrent.FutureUtils.doForward(FutureUtils.java:1387)
2023-02-21T02:55:31.2853361Z at
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$guardCompletionWithContextClassLoader$1(ClassLoadingUtils.java:93)
2023-02-21T02:55:31.2854202Z at
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68)
2023-02-21T02:55:31.2855038Z at
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$guardCompletionWithContextClassLoader$2(ClassLoadingUtils.java:92)
2023-02-21T02:55:31.2856169Z at
java.base/java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:859)
2023-02-21T02:55:31.2856854Z at
java.base/java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:837)
2023-02-21T02:55:31.2857914Z at
java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506)
2023-02-21T02:55:31.2858883Z at
java.base/java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:2088)
2023-02-21T02:55:31.2859608Z at
org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$1.onComplete(AkkaFutureUtils.java:45)
2023-02-21T02:55:31.2860403Z at
akka.dispatch.OnComplete.internal(Future.scala:299)
2023-02-21T02:55:31.2860981Z at
akka.dispatch.OnComplete.internal(Future.scala:297)
2023-02-21T02:55:31.2861479Z at
akka.dispatch.japi$CallbackBridge.apply(Future.scala:224)
2023-02-21T02:55:31.2862105Z at
akka.dispatch.japi$CallbackBridge.apply(Future.scala:221)
2023-02-21T02:55:31.2862641Z at
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60)
2023-02-21T02:55:31.2863475Z at
org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$DirectExecutionContext.execute(AkkaFutureUtils.java:65)
2023-02-21T02:55:31.2864186Z at
scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:68)
2023-02-21T02:55:31.2864815Z at
scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1(Promise.scala:284)
2023-02-21T02:55:31.2865551Z at
scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1$adapted(Promise.scala:284)
2023-02-21T02:55:31.2866258Z at
scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:284)
2023-02-21T02:55:31.2867225Z at
akka.pattern.PromiseActorRef.$bang(AskSupport.scala:621)
2023-02-21T02:55:31.2868176Z at
akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:25)
2023-02-21T02:55:31.2869251Z at
akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:23)
2023-02-21T02:55:31.2870247Z at
scala.concurrent.Future.$anonfun$andThen$1(Future.scala:532)
2023-02-21T02:55:31.2871042Z at
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:29)
2023-02-21T02:55:31.2871627Z at
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:29)
2023-02-21T02:55:31.2872194Z at
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60)
2023-02-21T02:55:31.2872995Z at
akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:63)
2023-02-21T02:55:31.2873686Z at
akka.dispatch.BatchingExecutor$BlockableBatch.$anonfun$run$1(BatchingExecutor.scala:100)
2023-02-21T02:55:31.2874337Z at
scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:12)
2023-02-21T02:55:31.2874924Z at
scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:81)
2023-02-21T02:55:31.2875671Z at
akka.dispatch.BatchingExecutor$BlockableBatch.run(BatchingExecutor.scala:100)
2023-02-21T02:55:31.2876555Z at
akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:49)
2023-02-21T02:55:31.2877380Z at
akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(ForkJoinExecutorConfigurator.scala:48)
2023-02-21T02:55:31.2878425Z at
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
2023-02-21T02:55:31.2879341Z at
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
2023-02-21T02:55:31.2879966Z at
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
2023-02-21T02:55:31.2880686Z at
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
2023-02-21T02:55:31.2881579Z at
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
2023-02-21T02:55:31.2882613Z Caused by:
org.apache.flink.runtime.messages.FlinkJobNotFoundException: Could not find
Flink job (865dcd87f4828dbeb3d93eb52e2636b1)
2023-02-21T02:55:31.2883418Z at
org.apache.flink.runtime.dispatcher.Dispatcher.requestExecutionGraphInfo(Dispatcher.java:840)
2023-02-21T02:55:31.2884143Z at
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
2023-02-21T02:55:31.2884776Z at
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
2023-02-21T02:55:31.2885594Z at
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2023-02-21T02:55:31.2886238Z at
java.base/java.lang.reflect.Method.invoke(Method.java:566)
2023-02-21T02:55:31.2886866Z at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRpcInvocation$1(AkkaRpcActor.java:304)
2023-02-21T02:55:31.2888130Z at
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83)
2023-02-21T02:55:31.2889116Z at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:302)
2023-02-21T02:55:31.2889803Z at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:217)
2023-02-21T02:55:31.2890492Z at
org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:78)
2023-02-21T02:55:31.2891177Z at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:163)
2023-02-21T02:55:31.2891911Z at
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24)
2023-02-21T02:55:31.2892457Z at
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20)
2023-02-21T02:55:31.2892993Z at
scala.PartialFunction.applyOrElse(PartialFunction.scala:123)
2023-02-21T02:55:31.2895111Z at
scala.PartialFunction.applyOrElse$(PartialFunction.scala:122)
2023-02-21T02:55:31.2896091Z at
akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20)
2023-02-21T02:55:31.2896686Z at
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
2023-02-21T02:55:31.2897376Z at
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
2023-02-21T02:55:31.2898183Z at
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
2023-02-21T02:55:31.2898744Z at
akka.actor.Actor.aroundReceive(Actor.scala:537)
2023-02-21T02:55:31.2899233Z at
akka.actor.Actor.aroundReceive$(Actor.scala:535)
2023-02-21T02:55:31.2899917Z at
akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220)
2023-02-21T02:55:31.2900591Z at
akka.actor.ActorCell.receiveMessage(ActorCell.scala:580)
2023-02-21T02:55:31.2901105Z at
akka.actor.ActorCell.invoke(ActorCell.scala:548)
2023-02-21T02:55:31.2901609Z at
akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270)
2023-02-21T02:55:31.2902108Z at akka.dispatch.Mailbox.run(Mailbox.scala:231)
2023-02-21T02:55:31.2902574Z at akka.dispatch.Mailbox.exec(Mailbox.scala:243)
2023-02-21T02:55:31.2902942Z ... 5 more
2023-02-21T02:55:31.2903202Z ]
2023-02-21T02:55:31.2903632Z at
org.apache.flink.runtime.rest.RestClient.parseResponse(RestClient.java:532)
2023-02-21T02:55:31.2904267Z at
org.apache.flink.runtime.rest.RestClient.lambda$submitRequest$3(RestClient.java:512)
2023-02-21T02:55:31.2904954Z at
java.base/java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:1072)
2023-02-21T02:55:31.2906030Z at
java.base/java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:478)
2023-02-21T02:55:31.2907202Z at
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
2023-02-21T02:55:31.2908229Z at
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
2023-02-21T02:55:31.2909067Z at
java.base/java.lang.Thread.run(Thread.java:829)
2023-02-21T02:55:31.2909868Z java.lang.RuntimeException:
java.util.concurrent.ExecutionException: java.lang.RuntimeException: Error
while waiting for job to be initialized
2023-02-21T02:55:31.2910569Z at
org.apache.flink.util.ExceptionUtils.rethrow(ExceptionUtils.java:319)
2023-02-21T02:55:31.2911203Z at
org.apache.flink.api.java.ExecutionEnvironment.executeAsync(ExecutionEnvironment.java:1061)
2023-02-21T02:55:31.2911880Z at
org.apache.flink.api.java.ExecutionEnvironment.execute(ExecutionEnvironment.java:958)
2023-02-21T02:55:31.2912543Z at
org.apache.flink.api.java.ExecutionEnvironment.execute(ExecutionEnvironment.java:942)
2023-02-21T02:55:31.2913351Z at
org.apache.flink.test.recovery.JobManagerHAProcessFailureRecoveryITCase.testJobManagerFailure(JobManagerHAProcessFailureRecoveryITCase.java:235)
2023-02-21T02:55:31.2914418Z at
org.apache.flink.test.recovery.JobManagerHAProcessFailureRecoveryITCase$4.run(JobManagerHAProcessFailureRecoveryITCase.java:336)
2023-02-21T02:55:31.2915321Z Caused by:
java.util.concurrent.ExecutionException: java.lang.RuntimeException: Error
while waiting for job to be initialized
2023-02-21T02:55:31.2916362Z at
java.base/java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:395)
2023-02-21T02:55:31.2917371Z at
java.base/java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1999)
2023-02-21T02:55:31.2918152Z at
org.apache.flink.api.java.ExecutionEnvironment.executeAsync(ExecutionEnvironment.java:1056)
2023-02-21T02:55:31.2918746Z ... 4 more
2023-02-21T02:55:31.2919167Z Caused by: java.lang.RuntimeException: Error while
waiting for job to be initialized
2023-02-21T02:55:31.2919789Z at
org.apache.flink.client.ClientUtils.waitUntilJobInitializationFinished(ClientUtils.java:160)
2023-02-21T02:55:31.2920795Z at
org.apache.flink.client.deployment.executors.AbstractSessionClusterExecutor.lambda$execute$2(AbstractSessionClusterExecutor.java:82)
2023-02-21T02:55:31.2921590Z at
org.apache.flink.util.function.FunctionUtils.lambda$uncheckedFunction$2(FunctionUtils.java:73)
2023-02-21T02:55:31.2922291Z at
java.base/java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:642)
2023-02-21T02:55:31.2922976Z at
java.base/java.util.concurrent.CompletableFuture$Completion.exec(CompletableFuture.java:479)
2023-02-21T02:55:31.2923612Z at
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
2023-02-21T02:55:31.2924246Z at
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
2023-02-21T02:55:31.2924870Z at
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
2023-02-21T02:55:31.2925869Z at
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
2023-02-21T02:55:31.2926840Z at
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
2023-02-21T02:55:31.2928107Z Caused by:
java.util.concurrent.ExecutionException:
org.apache.flink.runtime.rest.util.RestClientException:
[org.apache.flink.runtime.rest.NotFoundException: Job
865dcd87f4828dbeb3d93eb52e2636b1 not found
2023-02-21T02:55:31.2929103Z at
org.apache.flink.runtime.rest.handler.job.AbstractExecutionGraphHandler.lambda$handleRequest$1(AbstractExecutionGraphHandler.java:99)
2023-02-21T02:55:31.2929918Z at
java.base/java.util.concurrent.CompletableFuture.uniExceptionally(CompletableFuture.java:986)
2023-02-21T02:55:31.2930625Z at
java.base/java.util.concurrent.CompletableFuture$UniExceptionally.tryFire(CompletableFuture.java:970)
2023-02-21T02:55:31.2931331Z at
java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506)
2023-02-21T02:55:31.2932019Z at
java.base/java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:2088)
2023-02-21T02:55:31.2932847Z at
org.apache.flink.runtime.rest.handler.legacy.DefaultExecutionGraphCache.lambda$getExecutionGraphInternal$0(DefaultExecutionGraphCache.java:109)
2023-02-21T02:55:31.2933653Z at
java.base/java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:859)
2023-02-21T02:55:31.2934354Z at
java.base/java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:837)
2023-02-21T02:55:31.2935041Z at
java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506)
2023-02-21T02:55:31.2935800Z at
java.base/java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:2088)
2023-02-21T02:55:31.2936546Z at
org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$1(AkkaInvocationHandler.java:252)
2023-02-21T02:55:31.2937373Z at
java.base/java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:859)
2023-02-21T02:55:31.2938069Z at
java.base/java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:837)
2023-02-21T02:55:31.2938735Z at
java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506)
2023-02-21T02:55:31.2939420Z at
java.base/java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:2088)
2023-02-21T02:55:31.2940084Z at
org.apache.flink.util.concurrent.FutureUtils.doForward(FutureUtils.java:1387)
2023-02-21T02:55:31.2940976Z at
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$guardCompletionWithContextClassLoader$1(ClassLoadingUtils.java:93)
2023-02-21T02:55:31.2941878Z at
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68)
2023-02-21T02:55:31.2942741Z at
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$guardCompletionWithContextClassLoader$2(ClassLoadingUtils.java:92)
2023-02-21T02:55:31.2943874Z at
java.base/java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:859)
2023-02-21T02:55:31.2944905Z at
java.base/java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:837)
2023-02-21T02:55:31.2946145Z at
java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506)
2023-02-21T02:55:31.2947445Z at
java.base/java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:2088)
2023-02-21T02:55:31.2948814Z at
org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$1.onComplete(AkkaFutureUtils.java:45)
2023-02-21T02:55:31.2949586Z at
akka.dispatch.OnComplete.internal(Future.scala:299)
2023-02-21T02:55:31.2950094Z at
akka.dispatch.OnComplete.internal(Future.scala:297)
2023-02-21T02:55:31.2950593Z at
akka.dispatch.japi$CallbackBridge.apply(Future.scala:224)
2023-02-21T02:55:31.2951124Z at
akka.dispatch.japi$CallbackBridge.apply(Future.scala:221)
2023-02-21T02:55:31.2951658Z at
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60)
2023-02-21T02:55:31.2952329Z at
org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$DirectExecutionContext.execute(AkkaFutureUtils.java:65)
2023-02-21T02:55:31.2953030Z at
scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:68)
2023-02-21T02:55:31.2953666Z at
scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1(Promise.scala:284)
2023-02-21T02:55:31.2954331Z at
scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1$adapted(Promise.scala:284)
2023-02-21T02:55:31.2954993Z at
scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:284)
2023-02-21T02:55:31.2955657Z at
akka.pattern.PromiseActorRef.$bang(AskSupport.scala:621)
2023-02-21T02:55:31.2956281Z at
akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:25)
2023-02-21T02:55:31.2956990Z at
akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:23)
2023-02-21T02:55:31.2957690Z at
scala.concurrent.Future.$anonfun$andThen$1(Future.scala:532)
2023-02-21T02:55:31.2958217Z at
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:29)
2023-02-21T02:55:31.2958791Z at
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:29)
2023-02-21T02:55:31.2959355Z at
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60)
2023-02-21T02:55:31.2959956Z at
akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:63)
2023-02-21T02:55:31.2960634Z at
akka.dispatch.BatchingExecutor$BlockableBatch.$anonfun$run$1(BatchingExecutor.scala:100)
2023-02-21T02:55:31.2961275Z at
scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:12)
2023-02-21T02:55:31.2961851Z at
scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:81)
2023-02-21T02:55:31.2962458Z at
akka.dispatch.BatchingExecutor$BlockableBatch.run(BatchingExecutor.scala:100)
2023-02-21T02:55:31.2963051Z at
akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:49)
2023-02-21T02:55:31.2963698Z at
akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(ForkJoinExecutorConfigurator.scala:48)
2023-02-21T02:55:31.2964371Z at
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
2023-02-21T02:55:31.2965008Z at
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
2023-02-21T02:55:31.2965685Z at
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
2023-02-21T02:55:31.2966282Z at
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
2023-02-21T02:55:31.2967182Z at
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
2023-02-21T02:55:31.2967885Z Caused by:
org.apache.flink.runtime.messages.FlinkJobNotFoundException: Could not find
Flink job (865dcd87f4828dbeb3d93eb52e2636b1)
2023-02-21T02:55:31.2968617Z at
org.apache.flink.runtime.dispatcher.Dispatcher.requestExecutionGraphInfo(Dispatcher.java:840)
2023-02-21T02:55:31.2969240Z at
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
2023-02-21T02:55:31.2969871Z at
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
2023-02-21T02:55:31.2970572Z at
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2023-02-21T02:55:31.2971194Z at
java.base/java.lang.reflect.Method.invoke(Method.java:566)
2023-02-21T02:55:31.2971821Z at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRpcInvocation$1(AkkaRpcActor.java:304)
2023-02-21T02:55:31.2972583Z at
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83)
2023-02-21T02:55:31.2973315Z at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:302)
2023-02-21T02:55:31.2973989Z at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:217)
2023-02-21T02:55:31.2974672Z at
org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:78)
2023-02-21T02:55:31.2975357Z at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:163)
2023-02-21T02:55:31.2976023Z at
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24)
2023-02-21T02:55:31.2976569Z at
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20)
2023-02-21T02:55:31.2977202Z at
scala.PartialFunction.applyOrElse(PartialFunction.scala:123)
2023-02-21T02:55:31.2977747Z at
scala.PartialFunction.applyOrElse$(PartialFunction.scala:122)
2023-02-21T02:55:31.2978294Z at
akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20)
2023-02-21T02:55:31.2978874Z at
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
2023-02-21T02:55:31.2979448Z at
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
2023-02-21T02:55:31.2980015Z at
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
2023-02-21T02:55:31.2980540Z at
akka.actor.Actor.aroundReceive(Actor.scala:537)
2023-02-21T02:55:31.2981018Z at
akka.actor.Actor.aroundReceive$(Actor.scala:535)
2023-02-21T02:55:31.2981523Z at
akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220)
2023-02-21T02:55:31.2982351Z at
akka.actor.ActorCell.receiveMessage(ActorCell.scala:580)
2023-02-21T02:55:31.2982869Z at
akka.actor.ActorCell.invoke(ActorCell.scala:548)
2023-02-21T02:55:31.2983373Z at
akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270)
2023-02-21T02:55:31.2984077Z at akka.dispatch.Mailbox.run(Mailbox.scala:231)
2023-02-21T02:55:31.2984813Z at akka.dispatch.Mailbox.exec(Mailbox.scala:243)
2023-02-21T02:55:31.2985356Z ... 5 more
2023-02-21T02:55:31.2985899Z ]
2023-02-21T02:55:31.2986552Z at
java.base/java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:395)
2023-02-21T02:55:31.2987696Z at
java.base/java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1999)
2023-02-21T02:55:31.2988934Z at
org.apache.flink.client.deployment.executors.AbstractSessionClusterExecutor.lambda$execute$0(AbstractSessionClusterExecutor.java:83)
2023-02-21T02:55:31.2990327Z at
org.apache.flink.client.ClientUtils.waitUntilJobInitializationFinished(ClientUtils.java:144)
2023-02-21T02:55:31.2991209Z ... 9 more
2023-02-21T02:55:31.2992249Z Caused by:
org.apache.flink.runtime.rest.util.RestClientException:
[org.apache.flink.runtime.rest.NotFoundException: Job
865dcd87f4828dbeb3d93eb52e2636b1 not found
2023-02-21T02:55:31.2993861Z at
org.apache.flink.runtime.rest.handler.job.AbstractExecutionGraphHandler.lambda$handleRequest$1(AbstractExecutionGraphHandler.java:99)
2023-02-21T02:55:31.2995726Z at
java.base/java.util.concurrent.CompletableFuture.uniExceptionally(CompletableFuture.java:986)
2023-02-21T02:55:31.2997018Z at
java.base/java.util.concurrent.CompletableFuture$UniExceptionally.tryFire(CompletableFuture.java:970)
2023-02-21T02:55:31.2998343Z at
java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506)
2023-02-21T02:55:31.2999582Z at
java.base/java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:2088)
2023-02-21T02:55:31.3001073Z at
org.apache.flink.runtime.rest.handler.legacy.DefaultExecutionGraphCache.lambda$getExecutionGraphInternal$0(DefaultExecutionGraphCache.java:109)
2023-02-21T02:55:31.3002547Z at
java.base/java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:859)
2023-02-21T02:55:31.3003803Z at
java.base/java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:837)
2023-02-21T02:55:31.3005050Z at
java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506)
2023-02-21T02:55:31.3006400Z at
java.base/java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:2088)
2023-02-21T02:55:31.3007819Z at
org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$1(AkkaInvocationHandler.java:252)
2023-02-21T02:55:31.3009130Z at
java.base/java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:859)
2023-02-21T02:55:31.3010369Z at
java.base/java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:837)
2023-02-21T02:55:31.3011618Z at
java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506)
2023-02-21T02:55:31.3012850Z at
java.base/java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:2088)
2023-02-21T02:55:31.3014057Z at
org.apache.flink.util.concurrent.FutureUtils.doForward(FutureUtils.java:1387)
2023-02-21T02:55:31.3015430Z at
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$guardCompletionWithContextClassLoader$1(ClassLoadingUtils.java:93)
2023-02-21T02:55:31.3017072Z at
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68)
2023-02-21T02:55:31.3018675Z at
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$guardCompletionWithContextClassLoader$2(ClassLoadingUtils.java:92)
2023-02-21T02:55:31.3020090Z at
java.base/java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:859)
2023-02-21T02:55:31.3021349Z at
java.base/java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:837)
2023-02-21T02:55:31.3022586Z at
java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506)
2023-02-21T02:55:31.3023817Z at
java.base/java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:2088)
2023-02-21T02:55:31.3025098Z at
org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$1.onComplete(AkkaFutureUtils.java:45)
2023-02-21T02:55:31.3026300Z at
akka.dispatch.OnComplete.internal(Future.scala:299)
2023-02-21T02:55:31.3027343Z at
akka.dispatch.OnComplete.internal(Future.scala:297)
2023-02-21T02:55:31.3028280Z at
akka.dispatch.japi$CallbackBridge.apply(Future.scala:224)
2023-02-21T02:55:31.3029225Z at
akka.dispatch.japi$CallbackBridge.apply(Future.scala:221)
2023-02-21T02:55:31.3030192Z at
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60)
2023-02-21T02:55:31.3031368Z at
org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$DirectExecutionContext.execute(AkkaFutureUtils.java:65)
2023-02-21T02:55:31.3032622Z at
scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:68)
2023-02-21T02:55:31.3033778Z at
scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1(Promise.scala:284)
2023-02-21T02:55:31.3034994Z at
scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1$adapted(Promise.scala:284)
2023-02-21T02:55:31.3036449Z at
scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:284)
2023-02-21T02:55:31.3037750Z at
akka.pattern.PromiseActorRef.$bang(AskSupport.scala:621)
2023-02-21T02:55:31.3038841Z at
akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:25)
2023-02-21T02:55:31.3040136Z at
akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:23)
2023-02-21T02:55:31.3041272Z at
scala.concurrent.Future.$anonfun$andThen$1(Future.scala:532)
2023-02-21T02:55:31.3042246Z at
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:29)
2023-02-21T02:55:31.3043265Z at
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:29)
2023-02-21T02:55:31.3044254Z at
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60)
2023-02-21T02:55:31.3045318Z at
akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:63)
2023-02-21T02:55:31.3046585Z at
akka.dispatch.BatchingExecutor$BlockableBatch.$anonfun$run$1(BatchingExecutor.scala:100)
2023-02-21T02:55:31.3047878Z at
scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:12)
2023-02-21T02:55:31.3048937Z at
scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:81)
2023-02-21T02:55:31.3050026Z at
akka.dispatch.BatchingExecutor$BlockableBatch.run(BatchingExecutor.scala:100)
2023-02-21T02:55:31.3051083Z at
akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:49)
2023-02-21T02:55:31.3052217Z at
akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(ForkJoinExecutorConfigurator.scala:48)
2023-02-21T02:55:31.3053426Z at
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
2023-02-21T02:55:31.3054552Z at
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
2023-02-21T02:55:31.3055758Z at
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
2023-02-21T02:55:31.3056838Z at
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
2023-02-21T02:55:31.3058085Z at
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
2023-02-21T02:55:31.3059352Z Caused by:
org.apache.flink.runtime.messages.FlinkJobNotFoundException: Could not find
Flink job (865dcd87f4828dbeb3d93eb52e2636b1)
2023-02-21T02:55:31.3060839Z at
org.apache.flink.runtime.dispatcher.Dispatcher.requestExecutionGraphInfo(Dispatcher.java:840)
2023-02-21T02:55:31.3061965Z at
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
2023-02-21T02:55:31.3063112Z at
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
2023-02-21T02:55:31.3064427Z at
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2023-02-21T02:55:31.3065644Z at
java.base/java.lang.reflect.Method.invoke(Method.java:566)
2023-02-21T02:55:31.3066787Z at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRpcInvocation$1(AkkaRpcActor.java:304)
2023-02-21T02:55:31.3068263Z at
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83)
2023-02-21T02:55:31.3069602Z at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:302)
2023-02-21T02:55:31.3070823Z at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:217)
2023-02-21T02:55:31.3072079Z at
org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:78)
2023-02-21T02:55:31.3073314Z at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:163)
2023-02-21T02:55:31.3074413Z at
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24)
2023-02-21T02:55:31.3075385Z at
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20)
2023-02-21T02:55:31.3076411Z at
scala.PartialFunction.applyOrElse(PartialFunction.scala:123)
2023-02-21T02:55:31.3077469Z at
scala.PartialFunction.applyOrElse$(PartialFunction.scala:122)
2023-02-21T02:55:31.3078549Z at
akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20)
2023-02-21T02:55:31.3079640Z at
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
2023-02-21T02:55:31.3080675Z at
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
2023-02-21T02:55:31.3081667Z at
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
2023-02-21T02:55:31.3082630Z at
akka.actor.Actor.aroundReceive(Actor.scala:537)
2023-02-21T02:55:31.3083498Z at
akka.actor.Actor.aroundReceive$(Actor.scala:535)
2023-02-21T02:55:31.3084436Z at
akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220)
2023-02-21T02:55:31.3085418Z at
akka.actor.ActorCell.receiveMessage(ActorCell.scala:580)
2023-02-21T02:55:31.3086482Z at
akka.actor.ActorCell.invoke(ActorCell.scala:548)
2023-02-21T02:55:31.3087493Z at
akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270)
2023-02-21T02:55:31.3088381Z at akka.dispatch.Mailbox.run(Mailbox.scala:231)
2023-02-21T02:55:31.3089227Z at akka.dispatch.Mailbox.exec(Mailbox.scala:243)
2023-02-21T02:55:31.3089902Z ... 5 more
2023-02-21T02:55:31.3090360Z ]
2023-02-21T02:55:31.3091100Z at
org.apache.flink.runtime.rest.RestClient.parseResponse(RestClient.java:532)
2023-02-21T02:55:31.3092246Z at
org.apache.flink.runtime.rest.RestClient.lambda$submitRequest$3(RestClient.java:512)
2023-02-21T02:55:31.3093473Z at
java.base/java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:1072)
2023-02-21T02:55:31.3094714Z at
java.base/java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:478)
2023-02-21T02:55:31.3096011Z at
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
2023-02-21T02:55:31.3097311Z at
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
2023-02-21T02:55:31.3098254Z at
java.base/java.lang.Thread.run(Thread.java:829)
2023-02-21T02:55:31.3099486Z java.lang.AssertionError: The program encountered
a RuntimeException : java.util.concurrent.ExecutionException:
java.lang.RuntimeException: Error while waiting for job to be initialized
2023-02-21T02:55:31.3100764Z at org.junit.Assert.fail(Assert.java:89)
2023-02-21T02:55:31.3102043Z at
org.apache.flink.test.recovery.JobManagerHAProcessFailureRecoveryITCase.testDispatcherProcessFailure(JobManagerHAProcessFailureRecoveryITCase.java:385)
2023-02-21T02:55:31.3103463Z at
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
2023-02-21T02:55:31.3104554Z at
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
2023-02-21T02:55:31.3105992Z at
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2023-02-21T02:55:31.3107267Z at
java.base/java.lang.reflect.Method.invoke(Method.java:566)
2023-02-21T02:55:31.3108333Z at
org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
2023-02-21T02:55:31.3109519Z at
org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
2023-02-21T02:55:31.3110703Z at
org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
2023-02-21T02:55:31.3111859Z at
org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
2023-02-21T02:55:31.3112989Z at
org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
2023-02-21T02:55:31.3114056Z at
org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:54)
2023-02-21T02:55:31.3115121Z at
org.apache.flink.util.TestNameProvider$1.evaluate(TestNameProvider.java:45)
2023-02-21T02:55:31.3116232Z at
org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:61)
2023-02-21T02:55:31.3117327Z at
org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
2023-02-21T02:55:31.3118454Z at
org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100)
2023-02-21T02:55:31.3119546Z at
org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366)
2023-02-21T02:55:31.3120814Z at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103)
2023-02-21T02:55:31.3122067Z at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63)
2023-02-21T02:55:31.3123129Z at
org.junit.runners.ParentRunner$4.run(ParentRunner.java:331)
2023-02-21T02:55:31.3124104Z at
org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79)
2023-02-21T02:55:31.3125116Z at
org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329)
2023-02-21T02:55:31.3126219Z at
org.junit.runners.ParentRunner.access$100(ParentRunner.java:66)
2023-02-21T02:55:31.3127391Z at
org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293)
2023-02-21T02:55:31.3128349Z at
org.junit.runners.ParentRunner.run(ParentRunner.java:413)
2023-02-21T02:55:31.3129261Z at
org.junit.runners.Suite.runChild(Suite.java:128)
2023-02-21T02:55:31.3130123Z at
org.junit.runners.Suite.runChild(Suite.java:27)
2023-02-21T02:55:31.3131033Z at
org.junit.runners.ParentRunner$4.run(ParentRunner.java:331)
2023-02-21T02:55:31.3132034Z at
org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79)
2023-02-21T02:55:31.3133016Z at
org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329)
2023-02-21T02:55:31.3134029Z at
org.junit.runners.ParentRunner.access$100(ParentRunner.java:66)
2023-02-21T02:55:31.3135032Z at
org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293)
2023-02-21T02:55:31.3136166Z at
org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
2023-02-21T02:55:31.3137365Z at
org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
2023-02-21T02:55:31.3138433Z at
org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
2023-02-21T02:55:31.3139405Z at
org.junit.runners.ParentRunner.run(ParentRunner.java:413)
2023-02-21T02:55:31.3140313Z at
org.junit.runner.JUnitCore.run(JUnitCore.java:137)
2023-02-21T02:55:31.3141206Z at
org.junit.runner.JUnitCore.run(JUnitCore.java:115)
2023-02-21T02:55:31.3142224Z at
org.junit.vintage.engine.execution.RunnerExecutor.execute(RunnerExecutor.java:42)
2023-02-21T02:55:31.3143430Z at
org.junit.vintage.engine.VintageTestEngine.executeAllChildren(VintageTestEngine.java:80)
2023-02-21T02:55:31.3144585Z at
org.junit.vintage.engine.VintageTestEngine.execute(VintageTestEngine.java:72)
2023-02-21T02:55:31.3145888Z at
org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:107)
2023-02-21T02:55:31.3147372Z at
org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:88)
2023-02-21T02:55:31.3148760Z at
org.junit.platform.launcher.core.EngineExecutionOrchestrator.lambda$execute$0(EngineExecutionOrchestrator.java:54)
2023-02-21T02:55:31.3150232Z at
org.junit.platform.launcher.core.EngineExecutionOrchestrator.withInterceptedStreams(EngineExecutionOrchestrator.java:67)
2023-02-21T02:55:31.3151659Z at
org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:52)
2023-02-21T02:55:31.3152930Z at
org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:114)
2023-02-21T02:55:31.3154079Z at
org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:86)
2023-02-21T02:55:31.3155362Z at
org.junit.platform.launcher.core.DefaultLauncherSession$DelegatingLauncher.execute(DefaultLauncherSession.java:86)
2023-02-21T02:55:31.3156824Z at
org.junit.platform.launcher.core.SessionPerRequestLauncher.execute(SessionPerRequestLauncher.java:53)
2023-02-21T02:55:31.3158264Z at
org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.execute(JUnitPlatformProvider.java:188)
2023-02-21T02:55:31.3159634Z at
org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invokeAllTests(JUnitPlatformProvider.java:154)
2023-02-21T02:55:31.3160983Z at
org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invoke(JUnitPlatformProvider.java:124)
2023-02-21T02:55:31.3162457Z at
org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:428)
2023-02-21T02:55:31.3163692Z at
org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:162)
2023-02-21T02:55:31.3164800Z at
org.apache.maven.surefire.booter.ForkedBooter.run(ForkedBooter.java:562)
2023-02-21T02:55:31.3165976Z at
org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:548)
{code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
