2021-05-07T10:56:20.9429367Z May 07 10:56:20 [ERROR] Tests run: 13, Failures: 0, Errors: 1, Skipped: 0, Time elapsed: 33.441 s <<< FAILURE! - in org.apache.flink.test.checkpointing.SavepointITCase
2021-05-07T10:56:20.9445862Z May 07 10:56:20 [ERROR] testShouldAddEntropyToSavepointPath(org.apache.flink.test.checkpointing.SavepointITCase) Time elapsed: 2.083 s <<< ERROR!
2021-05-07T10:56:20.9447106Z May 07 10:56:20 java.util.concurrent.ExecutionException: java.util.concurrent.CompletionException: org.apache.flink.runtime.checkpoint.CheckpointException: Checkpoint triggering task Sink: Unnamed (3/4) of job 4e155a20f0a7895043661a6446caf1cb has not being executed at the moment. Aborting checkpoint. Failure reason: Not all required tasks are currently running.
2021-05-07T10:56:20.9448194Z May 07 10:56:20 at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357)
2021-05-07T10:56:20.9448797Z May 07 10:56:20 at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1908)
2021-05-07T10:56:20.9449428Z May 07 10:56:20 at org.apache.flink.test.checkpointing.SavepointITCase.submitJobAndTakeSavepoint(SavepointITCase.java:305)
2021-05-07T10:56:20.9450160Z May 07 10:56:20 at org.apache.flink.test.checkpointing.SavepointITCase.testShouldAddEntropyToSavepointPath(SavepointITCase.java:273)
2021-05-07T10:56:20.9450785Z May 07 10:56:20 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
2021-05-07T10:56:20.9451331Z May 07 10:56:20 at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
2021-05-07T10:56:20.9451940Z May 07 10:56:20 at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2021-05-07T10:56:20.9452498Z May 07 10:56:20 at java.lang.reflect.Method.invoke(Method.java:498)
2021-05-07T10:56:20.9453247Z May 07 10:56:20 at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
2021-05-07T10:56:20.9454007Z May 07 10:56:20 at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
2021-05-07T10:56:20.9454687Z May 07 10:56:20 at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
2021-05-07T10:56:20.9455302Z May 07 10:56:20 at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
2021-05-07T10:56:20.9455909Z May 07 10:56:20 at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
2021-05-07T10:56:20.9456493Z May 07 10:56:20 at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:48)
2021-05-07T10:56:20.9457074Z May 07 10:56:20 at org.apache.flink.util.TestNameProvider$1.evaluate(TestNameProvider.java:45)
2021-05-07T10:56:20.9457636Z May 07 10:56:20 at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
2021-05-07T10:56:20.9458157Z May 07 10:56:20 at org.junit.rules.RunRules.evaluate(RunRules.java:20)
2021-05-07T10:56:20.9458678Z May 07 10:56:20 at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
2021-05-07T10:56:20.9459252Z May 07 10:56:20 at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
2021-05-07T10:56:20.9459865Z May 07 10:56:20 at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
2021-05-07T10:56:20.9460433Z May 07 10:56:20 at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
2021-05-07T10:56:20.9461058Z May 07 10:56:20 at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
2021-05-07T10:56:20.9461607Z May 07 10:56:20 at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
2021-05-07T10:56:20.9462159Z May 07 10:56:20 at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
2021-05-07T10:56:20.9462705Z May 07 10:56:20 at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
2021-05-07T10:56:20.9463243Z May 07 10:56:20 at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
2021-05-07T10:56:20.9463812Z May 07 10:56:20 at org.apache.maven.surefire.junit4.JUnit4Provider.execute(JUnit4Provider.java:365)
2021-05-07T10:56:20.9464436Z May 07 10:56:20 at org.apache.maven.surefire.junit4.JUnit4Provider.executeWithRerun(JUnit4Provider.java:273)
2021-05-07T10:56:20.9465073Z May 07 10:56:20 at org.apache.maven.surefire.junit4.JUnit4Provider.executeTestSet(JUnit4Provider.java:238)
2021-05-07T10:56:20.9465688Z May 07 10:56:20 at org.apache.maven.surefire.junit4.JUnit4Provider.invoke(JUnit4Provider.java:159)
2021-05-07T10:56:20.9466316Z May 07 10:56:20 at org.apache.maven.surefire.booter.ForkedBooter.invokeProviderInSameClassLoader(ForkedBooter.java:384)
2021-05-07T10:56:20.9466969Z May 07 10:56:20 at org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:345)
2021-05-07T10:56:20.9467579Z May 07 10:56:20 at org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:126)
2021-05-07T10:56:20.9468169Z May 07 10:56:20 at org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:418)
2021-05-07T10:56:20.9469189Z May 07 10:56:20 Caused by: java.util.concurrent.CompletionException: org.apache.flink.runtime.checkpoint.CheckpointException: Checkpoint triggering task Sink: Unnamed (3/4) of job 4e155a20f0a7895043661a6446caf1cb has not being executed at the moment. Aborting checkpoint. Failure reason: Not all required tasks are currently running.
2021-05-07T10:56:20.9470242Z May 07 10:56:20 at java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:292)
2021-05-07T10:56:20.9470862Z May 07 10:56:20 at java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:308)
2021-05-07T10:56:20.9471473Z May 07 10:56:20 at java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:607)
2021-05-07T10:56:20.9472078Z May 07 10:56:20 at java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591)
2021-05-07T10:56:20.9472743Z May 07 10:56:20 at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
2021-05-07T10:56:20.9473360Z May 07 10:56:20 at java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1990)
2021-05-07T10:56:20.9474022Z May 07 10:56:20 at org.apache.flink.runtime.checkpoint.CheckpointCoordinator.lambda$null$0(CheckpointCoordinator.java:482)
2021-05-07T10:56:20.9474672Z May 07 10:56:20 at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
2021-05-07T10:56:20.9475283Z May 07 10:56:20 at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
2021-05-07T10:56:20.9475901Z May 07 10:56:20 at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
2021-05-07T10:56:20.9476514Z May 07 10:56:20 at java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1990)
2021-05-07T10:56:20.9477247Z May 07 10:56:20 at org.apache.flink.runtime.checkpoint.CheckpointCoordinator$CheckpointTriggerRequest.completeExceptionally(CheckpointCoordinator.java:2047)
2021-05-07T10:56:20.9478016Z May 07 10:56:20 at org.apache.flink.runtime.checkpoint.CheckpointCoordinator.onTriggerFailure(CheckpointCoordinator.java:853)
2021-05-07T10:56:20.9478753Z May 07 10:56:20 at org.apache.flink.runtime.checkpoint.CheckpointCoordinator.lambda$startTriggeringCheckpoint$7(CheckpointCoordinator.java:608)
2021-05-07T10:56:20.9479430Z May 07 10:56:20 at java.util.concurrent.CompletableFuture.uniHandle(CompletableFuture.java:836)
2021-05-07T10:56:20.9480080Z May 07 10:56:20 at java.util.concurrent.CompletableFuture$UniHandle.tryFire(CompletableFuture.java:811)
2021-05-07T10:56:20.9480691Z May 07 10:56:20 at java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:456)
2021-05-07T10:56:20.9481278Z May 07 10:56:20 at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
2021-05-07T10:56:20.9481820Z May 07 10:56:20 at java.util.concurrent.FutureTask.run(FutureTask.java:266)
2021-05-07T10:56:20.9482457Z May 07 10:56:20 at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
2021-05-07T10:56:20.9483190Z May 07 10:56:20 at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
2021-05-07T10:56:20.9483845Z May 07 10:56:20 at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
2021-05-07T10:56:20.9484440Z May 07 10:56:20 at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
2021-05-07T10:56:20.9484963Z May 07 10:56:20 at java.lang.Thread.run(Thread.java:748)
2021-05-07T10:56:20.9485836Z May 07 10:56:20 Caused by: org.apache.flink.runtime.checkpoint.CheckpointException: Checkpoint triggering task Sink: Unnamed (3/4) of job 4e155a20f0a7895043661a6446caf1cb has not being executed at the moment. Aborting checkpoint. Failure reason: Not all required tasks are currently running.
2021-05-07T10:56:20.9486869Z May 07 10:56:20 at org.apache.flink.runtime.checkpoint.DefaultCheckpointPlanCalculator.checkTasksStarted(DefaultCheckpointPlanCalculator.java:152)
2021-05-07T10:56:20.9487681Z May 07 10:56:20 at org.apache.flink.runtime.checkpoint.DefaultCheckpointPlanCalculator.lambda$calculateCheckpointPlan$1(DefaultCheckpointPlanCalculator.java:114)
2021-05-07T10:56:20.9488413Z May 07 10:56:20 at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1604)
2021-05-07T10:56:20.9489056Z May 07 10:56:20 at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRunAsync(AkkaRpcActor.java:440)
2021-05-07T10:56:20.9489678Z May 07 10:56:20 at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:208)
2021-05-07T10:56:20.9490336Z May 07 10:56:20 at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:77)
2021-05-07T10:56:20.9490985Z May 07 10:56:20 at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:158)
2021-05-07T10:56:20.9491615Z May 07 10:56:20 at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:26)
2021-05-07T10:56:20.9492156Z May 07 10:56:20 at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:21)
2021-05-07T10:56:20.9492706Z May 07 10:56:20 at scala.PartialFunction$class.applyOrElse(PartialFunction.scala:123)
2021-05-07T10:56:20.9493267Z May 07 10:56:20 at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:21)
2021-05-07T10:56:20.9493925Z May 07 10:56:20 at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:170)
2021-05-07T10:56:20.9494489Z May 07 10:56:20 at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
2021-05-07T10:56:20.9495050Z May 07 10:56:20 at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
2021-05-07T10:56:20.9495583Z May 07 10:56:20 at akka.actor.Actor$class.aroundReceive(Actor.scala:517)
2021-05-07T10:56:20.9496120Z May 07 10:56:20 at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:225)
2021-05-07T10:56:20.9496662Z May 07 10:56:20 at akka.actor.ActorCell.receiveMessage(ActorCell.scala:592)
2021-05-07T10:56:20.9497176Z May 07 10:56:20 at akka.actor.ActorCell.invoke(ActorCell.scala:561)
2021-05-07T10:56:20.9497684Z May 07 10:56:20 at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:258)
2021-05-07T10:56:20.9498178Z May 07 10:56:20 at akka.dispatch.Mailbox.run(Mailbox.scala:225)
2021-05-07T10:56:20.9498656Z May 07 10:56:20 at akka.dispatch.Mailbox.exec(Mailbox.scala:235)
2021-05-07T10:56:20.9499226Z May 07 10:56:20 at akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
2021-05-07T10:56:20.9499796Z May 07 10:56:20 at akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
2021-05-07T10:56:20.9500370Z May 07 10:56:20 at akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
2021-05-07T10:56:20.9500950Z May 07 10:56:20 at akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
Bug
Blocker
