Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-22420

UnalignedCheckpointITCase failed

    XMLWordPrintableJSON

Details

    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.

      Attachments

        Issue Links

          Activity

            People

              trohrmann Till Rohrmann
              maguowei Guowei Ma
              Votes:
              0 Vote for this issue
              Watchers:
              5 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: