2022-03-21T17:04:48.7388935Z Mar 21 17:04:48 [ERROR] TaskManagerProcessFailureStreamingRecoveryITCase>AbstractTaskManagerProcessFailureRecoveryTest.testTaskManagerProcessFailure:201 The program encountered a RestClientException : [org.apache.flink.runtime.rest.handler.RestHandlerException: org.apache.flink.runtime.messages.FlinkJobNotFoundException: Could not find Flink job (e5d2bef6fe1da660c2da45ef89c9acdb)
2022-03-21T17:04:48.7391533Z Mar 21 17:04:48 at org.apache.flink.runtime.rest.handler.job.JobExecutionResultHandler.propagateException(JobExecutionResultHandler.java:94)
2022-03-21T17:04:48.7393502Z Mar 21 17:04:48 at org.apache.flink.runtime.rest.handler.job.JobExecutionResultHandler.lambda$handleRequest$1(JobExecutionResultHandler.java:84)
2022-03-21T17:04:48.7394967Z Mar 21 17:04:48 at java.util.concurrent.CompletableFuture.uniExceptionally(CompletableFuture.java:884)
2022-03-21T17:04:48.7396569Z Mar 21 17:04:48 at java.util.concurrent.CompletableFuture$UniExceptionally.tryFire(CompletableFuture.java:866)
2022-03-21T17:04:48.7397895Z Mar 21 17:04:48 at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
2022-03-21T17:04:48.7399156Z Mar 21 17:04:48 at java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1990)
2022-03-21T17:04:48.7401447Z Mar 21 17:04:48 at org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$1(AkkaInvocationHandler.java:252)
2022-03-21T17:04:48.7402979Z Mar 21 17:04:48 at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
2022-03-21T17:04:48.7403835Z Mar 21 17:04:48 at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
2022-03-21T17:04:48.7404613Z Mar 21 17:04:48 at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
2022-03-21T17:04:48.7405337Z Mar 21 17:04:48 at java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1990)
2022-03-21T17:04:48.7406351Z Mar 21 17:04:48 at org.apache.flink.util.concurrent.FutureUtils.doForward(FutureUtils.java:1387)
2022-03-21T17:04:48.7407088Z Mar 21 17:04:48 at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$null$1(ClassLoadingUtils.java:93)
2022-03-21T17:04:48.7408037Z Mar 21 17:04:48 at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68)
2022-03-21T17:04:48.7408971Z Mar 21 17:04:48 at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$guardCompletionWithContextClassLoader$2(ClassLoadingUtils.java:92)
2022-03-21T17:04:48.7409816Z Mar 21 17:04:48 at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
2022-03-21T17:04:48.7410621Z Mar 21 17:04:48 at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
2022-03-21T17:04:48.7411616Z Mar 21 17:04:48 at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
2022-03-21T17:04:48.7412463Z Mar 21 17:04:48 at java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1990)
2022-03-21T17:04:48.7413295Z Mar 21 17:04:48 at org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$1.onComplete(AkkaFutureUtils.java:45)
2022-03-21T17:04:48.7413957Z Mar 21 17:04:48 at akka.dispatch.OnComplete.internal(Future.scala:299)
2022-03-21T17:04:48.7414636Z Mar 21 17:04:48 at akka.dispatch.OnComplete.internal(Future.scala:297)
2022-03-21T17:04:48.7415230Z Mar 21 17:04:48 at akka.dispatch.japi$CallbackBridge.apply(Future.scala:224)
2022-03-21T17:04:48.7416123Z Mar 21 17:04:48 at akka.dispatch.japi$CallbackBridge.apply(Future.scala:221)
2022-03-21T17:04:48.7416843Z Mar 21 17:04:48 at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60)
2022-03-21T17:04:48.7417586Z Mar 21 17:04:48 at org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$DirectExecutionContext.execute(AkkaFutureUtils.java:65)
2022-03-21T17:04:48.7418360Z Mar 21 17:04:48 at scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:68)
2022-03-21T17:04:48.7419058Z Mar 21 17:04:48 at scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1(Promise.scala:284)
2022-03-21T17:04:48.7419820Z Mar 21 17:04:48 at scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1$adapted(Promise.scala:284)
2022-03-21T17:04:48.7420561Z Mar 21 17:04:48 at scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:284)
2022-03-21T17:04:48.7421202Z Mar 21 17:04:48 at akka.pattern.PromiseActorRef.$bang(AskSupport.scala:621)
2022-03-21T17:04:48.7422098Z Mar 21 17:04:48 at akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:25)
2022-03-21T17:04:48.7422988Z Mar 21 17:04:48 at akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:23)
2022-03-21T17:04:48.7423685Z Mar 21 17:04:48 at scala.concurrent.Future.$anonfun$andThen$1(Future.scala:532)
2022-03-21T17:04:48.7424298Z Mar 21 17:04:48 at scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:29)
2022-03-21T17:04:48.7424929Z Mar 21 17:04:48 at scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:29)
2022-03-21T17:04:48.7425568Z Mar 21 17:04:48 at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60)
2022-03-21T17:04:48.7426628Z Mar 21 17:04:48 at akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:63)
2022-03-21T17:04:48.7427381Z Mar 21 17:04:48 at akka.dispatch.BatchingExecutor$BlockableBatch.$anonfun$run$1(BatchingExecutor.scala:100)
2022-03-21T17:04:48.7428227Z Mar 21 17:04:48 at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:12)
2022-03-21T17:04:48.7428876Z Mar 21 17:04:48 at scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:81)
2022-03-21T17:04:48.7429550Z Mar 21 17:04:48 at akka.dispatch.BatchingExecutor$BlockableBatch.run(BatchingExecutor.scala:100)
2022-03-21T17:04:48.7430217Z Mar 21 17:04:48 at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:49)
2022-03-21T17:04:48.7430932Z Mar 21 17:04:48 at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(ForkJoinExecutorConfigurator.scala:48)
2022-03-21T17:04:48.7431658Z Mar 21 17:04:48 at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
2022-03-21T17:04:48.7432321Z Mar 21 17:04:48 at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056)
2022-03-21T17:04:48.7432963Z Mar 21 17:04:48 at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692)
2022-03-21T17:04:48.7433633Z Mar 21 17:04:48 at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175)
2022-03-21T17:04:48.7434466Z Mar 21 17:04:48 Caused by: java.util.concurrent.CompletionException: org.apache.flink.runtime.messages.FlinkJobNotFoundException: Could not find Flink job (e5d2bef6fe1da660c2da45ef89c9acdb)
2022-03-21T17:04:48.7435418Z Mar 21 17:04:48 at java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:292)
2022-03-21T17:04:48.7436386Z Mar 21 17:04:48 at java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:308)
2022-03-21T17:04:48.7437369Z Mar 21 17:04:48 at java.util.concurrent.CompletableFuture.uniCompose(CompletableFuture.java:957)
2022-03-21T17:04:48.7438509Z Mar 21 17:04:48 at java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:940)
2022-03-21T17:04:48.7439057Z Mar 21 17:04:48 ... 44 more
2022-03-21T17:04:48.7439755Z Mar 21 17:04:48 Caused by: org.apache.flink.runtime.messages.FlinkJobNotFoundException: Could not find Flink job (e5d2bef6fe1da660c2da45ef89c9acdb)
2022-03-21T17:04:48.7440554Z Mar 21 17:04:48 at org.apache.flink.runtime.dispatcher.Dispatcher.lambda$requestJobStatus$17(Dispatcher.java:781)
2022-03-21T17:04:48.7441221Z Mar 21 17:04:48 at java.util.Optional.orElseGet(Optional.java:267)
2022-03-21T17:04:48.7441838Z Mar 21 17:04:48 at org.apache.flink.runtime.dispatcher.Dispatcher.requestJobStatus(Dispatcher.java:775)
2022-03-21T17:04:48.7442470Z Mar 21 17:04:48 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
2022-03-21T17:04:48.7443105Z Mar 21 17:04:48 at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
2022-03-21T17:04:48.7443816Z Mar 21 17:04:48 at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2022-03-21T17:04:48.7444570Z Mar 21 17:04:48 at java.lang.reflect.Method.invoke(Method.java:498)
2022-03-21T17:04:48.7445258Z Mar 21 17:04:48 at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRpcInvocation$1(AkkaRpcActor.java:304)
2022-03-21T17:04:48.7446739Z Mar 21 17:04:48 at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83)
2022-03-21T17:04:48.7447916Z Mar 21 17:04:48 at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:302)
2022-03-21T17:04:48.7448676Z Mar 21 17:04:48 at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:217)
2022-03-21T17:04:48.7449454Z Mar 21 17:04:48 at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:78)
2022-03-21T17:04:48.7450408Z Mar 21 17:04:48 at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:163)
2022-03-21T17:04:48.7451251Z Mar 21 17:04:48 at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24)
2022-03-21T17:04:48.7451875Z Mar 21 17:04:48 at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20)
2022-03-21T17:04:48.7452476Z Mar 21 17:04:48 at scala.PartialFunction.applyOrElse(PartialFunction.scala:123)
2022-03-21T17:04:48.7453099Z Mar 21 17:04:48 at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122)
2022-03-21T17:04:48.7453724Z Mar 21 17:04:48 at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20)
2022-03-21T17:04:48.7454561Z Mar 21 17:04:48 at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
2022-03-21T17:04:48.7455215Z Mar 21 17:04:48 at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
2022-03-21T17:04:48.7456450Z Mar 21 17:04:48 at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
2022-03-21T17:04:48.7457055Z Mar 21 17:04:48 at akka.actor.Actor.aroundReceive(Actor.scala:537)
2022-03-21T17:04:48.7457618Z Mar 21 17:04:48 at akka.actor.Actor.aroundReceive$(Actor.scala:535)
2022-03-21T17:04:48.7458216Z Mar 21 17:04:48 at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220)
2022-03-21T17:04:48.7458837Z Mar 21 17:04:48 at akka.actor.ActorCell.receiveMessage(ActorCell.scala:580)
2022-03-21T17:04:48.7459424Z Mar 21 17:04:48 at akka.actor.ActorCell.invoke(ActorCell.scala:548)
2022-03-21T17:04:48.7459996Z Mar 21 17:04:48 at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270)
2022-03-21T17:04:48.7460538Z Mar 21 17:04:48 at akka.dispatch.Mailbox.run(Mailbox.scala:231)
2022-03-21T17:04:48.7461087Z Mar 21 17:04:48 at akka.dispatch.Mailbox.exec(Mailbox.scala:243)
2022-03-21T17:04:48.7461539Z Mar 21 17:04:48 ... 4 more
Bug
Minor