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

CheckpointCoordinatorTest#testMinCheckpointPause

    XMLWordPrintableJSON

Details

    Description

      The test triggers checkpoints, waits for the CC to have stored a pending checkpoint, and then sends an acknowledge.
      The acknowledge can fail with an NPE because the PendingCheckpoint#checkpointTargetLocation hasn't been set yet. This doesn't happen synchronously with the PendingCheckpoint being added to CheckpointCoordinator#pendingCheckpoints.

      Apr 01 19:57:36 [ERROR] org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest.testMinCheckpointPause  Time elapsed: 0.012 s  <<< ERROR!
      Apr 01 19:57:36 org.apache.flink.runtime.checkpoint.CheckpointException: Could not finalize the pending checkpoint 1. Failure reason: Failure to finalize checkpoint.
      Apr 01 19:57:36 	at org.apache.flink.runtime.checkpoint.CheckpointCoordinator.finalizeCheckpoint(CheckpointCoordinator.java:1354)
      Apr 01 19:57:36 	at org.apache.flink.runtime.checkpoint.CheckpointCoordinator.completePendingCheckpoint(CheckpointCoordinator.java:1241)
      Apr 01 19:57:36 	at org.junit.vintage.engine.VintageTestEngine.execute(VintageTestEngine.java:72)
      ...
      Apr 01 19:57:36 Caused by: java.lang.NullPointerException
      Apr 01 19:57:36 	at org.apache.flink.runtime.checkpoint.PendingCheckpoint.finalizeCheckpoint(PendingCheckpoint.java:327)
      Apr 01 19:57:36 	at org.apache.flink.runtime.checkpoint.CheckpointCoordinator.finalizeCheckpoint(CheckpointCoordinator.java:1337)
      Apr 01 19:57:36 	... 50 more
      

      Attachments

        Issue Links

          Activity

            People

              chesnay Chesnay Schepler
              chesnay Chesnay Schepler
              Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: