Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-29281 Replace Akka by gRPC-based RPC implementation
  3. FLINK-29340

ResourceManagerTest#testProcessResourceRequirementsWhenRecoveryFinished prone to race condition

    XMLWordPrintableJSON

Details

    Description

      The test incorrectly assumes that the declareRequiredResources has already been run when calling runInMainThread, while the RPC could still be in flight.
      This can result in the test failing because within runInMainThread the test assumes that completing the readyToServeFuture will immediately result in the processing of resources, due to this workflow having been set up within delcareRequiredResources. Without it it will just fail because the completion of the future has in practice no effect.

      Attachments

        Issue Links

          Activity

            People

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

              Dates

                Created:
                Updated:
                Resolved: