Robert Metzger created FLINK-22593:
-------------------------------------- Summary: SavepointITCase.testShouldAddEntropyToSavepointPath unstable Key: FLINK-22593 URL: https://issues.apache.org/jira/browse/FLINK-22593 Project: Flink Issue Type: Bug Components: Runtime / Checkpointing Affects Versions: 1.14.0 Reporter: Robert Metzger https://dev.azure.com/rmetzger/Flink/_build/results?buildId=9072&view=logs&j=cc649950-03e9-5fae-8326-2f1ad744b536&t=51cab6ca-669f-5dc0-221d-1e4f7dc4fc85 {code} 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) {code} -- This message was sent by Atlassian Jira (v8.3.4#803005) |
Free forum by Nabble | Edit this page |