You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/01/31 01:46:00 UTC

[jira] [Created] (FLINK-21215) UnalignedCheckpointITCase.execute

Guowei Ma created FLINK-21215:
---------------------------------

             Summary: UnalignedCheckpointITCase.execute
                 Key: FLINK-21215
                 URL: https://issues.apache.org/jira/browse/FLINK-21215
             Project: Flink
          Issue Type: Bug
          Components: Runtime / Checkpointing
    Affects Versions: 1.13.0
            Reporter: Guowei Ma


[https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=12691&view=logs&j=34f41360-6c0d-54d3-11a1-0292a2def1d9&t=2d56e022-1ace-542f-bf1a-b37dd63243f2&l=9146]
 
 
ERROR] Tests run: 11, Failures: 0, Errors: 1, Skipped: 0, Time elapsed: 101.136 s <<< FAILURE! - in org.apache.flink.test.checkpointing.UnalignedCheckpointITCase 
[ERROR] execute[parallel pipeline with local channels, p = 5](org.apache.flink.test.checkpointing.UnalignedCheckpointITCase) Time elapsed: 2.263 s <<< ERROR! 
org.apache.flink.runtime.client.JobExecutionException: Job execution failed. 
 at org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144) 
 at org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$3(MiniClusterJobClient.java:137) 
 at java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616) 
 at java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591) 
 at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) 
 at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) 
 at org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$0(AkkaInvocationHandler.java:238) 
 at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774) 
 at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750) 
 at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) 
 at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) 
 at org.apache.flink.runtime.concurrent.FutureUtils$1.onComplete(FutureUtils.java:1046) 
 at akka.dispatch.OnComplete.internal(Future.scala:264) 
 at akka.dispatch.OnComplete.internal(Future.scala:261) 
 at akka.dispatch.japi$CallbackBridge.apply(Future.scala:191) 
 at akka.dispatch.japi$CallbackBridge.apply(Future.scala:188) 
 at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:36) 
 at org.apache.flink.runtime.concurrent.Executors$DirectExecutionContext.execute(Executors.java:73) 
 at scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:44) 
 at scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:252) 
 at akka.pattern.PromiseActorRef.$bang(AskSupport.scala:572) 
 at akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:22) 
 at akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:21) 
 at scala.concurrent.Future$$anonfun$andThen$1.apply(Future.scala:436) 
 at scala.concurrent.Future$$anonfun$andThen$1.apply(Future.scala:435) 
 at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:36) 
 at akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:55) 
 at akka.dispatch.BatchingExecutor$BlockableBatch$$anonfun$run$1.apply$mcV$sp(BatchingExecutor.scala:91) 
 at akka.dispatch.BatchingExecutor$BlockableBatch$$anonfun$run$1.apply(BatchingExecutor.scala:91) 
 at akka.dispatch.BatchingExecutor$BlockableBatch$$anonfun$run$1.apply(BatchingExecutor.scala:91) 
 at scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:72) 
 
 
 
 
 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)