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

          blocks

          Technical Debt - FLINK-26995 Enable fork-reuse for all unit tests

          • Major - Major loss of function.
          • Closed
          is caused by

          Bug - A problem which impairs or prevents the functions of the product. FLINK-26049 The tolerable-failed-checkpoints logic is invalid when checkpoint trigger failed

          • Major - Major loss of function.
          • Closed
          is duplicated by

          Bug - A problem which impairs or prevents the functions of the product. FLINK-27216 CheckpointCoordinatorTest.testMinCheckpointPause failed on azure

          • Major - Major loss of function.
          • Closed
          links to

          Web Link GitHub Pull Request #19356

          Web Link GitHub Pull Request #19865

          Activity

            People

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

              Dates

                Created:
                Updated:
                Resolved: