[FLINK-22420] UnalignedCheckpointITCase failed

• Type: Bug
• Status: Closed
• Priority: Minor
• Resolution: Cannot Reproduce
• Affects Version/s: 1.14.0
• Component/s: Runtime / Checkpointing
• Labels: auto-deprioritized-major pull-request-available test-stability
• Assignee: Till Rohrmann
• Reporter: Guowei Ma
• Created: 23/Apr/21 03:22
• Updated: 23/Sep/21 17:55
• Resolved: 07/Jul/21 12:54

Description

https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=17052&view=logs&j=34f41360-6c0d-54d3-11a1-0292a2def1d9&t=2d56e022-1ace-542f-bf1a-b37dd63243f2&l=9442

Apr 22 14:28:21 	at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:21)
Apr 22 14:28:21 	at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:170)
Apr 22 14:28:21 	at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
Apr 22 14:28:21 	at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
Apr 22 14:28:21 	at akka.actor.Actor$class.aroundReceive(Actor.scala:517)
Apr 22 14:28:21 	at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:225)
Apr 22 14:28:21 	at akka.actor.ActorCell.receiveMessage(ActorCell.scala:592)
Apr 22 14:28:21 	at akka.actor.ActorCell.invoke(ActorCell.scala:561)
Apr 22 14:28:21 	at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:258)
Apr 22 14:28:21 	at akka.dispatch.Mailbox.run(Mailbox.scala:225)
Apr 22 14:28:21 	at akka.dispatch.Mailbox.exec(Mailbox.scala:235)
Apr 22 14:28:21 	at akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
Apr 22 14:28:21 	at akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
Apr 22 14:28:21 	at akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
Apr 22 14:28:21 	at akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
Apr 22 14:28:21 Caused by: org.apache.flink.util.FlinkException: An OperatorEvent from an OperatorCoordinator to a task was lost. Triggering task failover to ensure consistency. Event: '[NoMoreSplitEvent]', targetTask: Source: source (1/1) - execution #5
Apr 22 14:28:21 	... 26 more
Apr 22 14:28:21 

As described in the comment https://issues.apache.org/jira/browse/FLINK-21996?focusedCommentId=17326449&page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel#comment-17326449 we might need to adjust the tests to allow failover.

Issue Links

• is caused by: FLINK-21996 Transient RPC failure without TaskManager failure can lead to split assignment loss
• is related to: FLINK-21996 Transient RPC failure without TaskManager failure can lead to split assignment loss
• relates to: FLINK-22397 OrcFileSystemITCase fails on Azure
• links to: GitHub Pull Request #16231