Uploaded image for project: 'Nuxeo Platform'
  1. Nuxeo Platform
  2. NXP-27674

Fix Stream processor drainAndStop timeout

    XMLWordPrintable

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Minor
    • Resolution: Fixed
    • Affects Version/s: 9.10, 10.10, 11.1-SNAPSHOT
    • Fix Version/s: 9.10-HF34, 10.10-HF10, 11.1, 2021.0
    • Component/s: Streams

      Description

      org.nuxeo.lib.stream.computation.StreamProcessor#drainAndStop is used to terminate processors after trying to process remaining records in the stream.
      This is used in many unit tests and now in the repair Works operation NXP-27673.

      This method takes a timeout parameter but incorrectly.
      The drain will stop before the timeout and while there are still records to process if the processing of a record or timer takes more than 1 second.

      This is a possible cause of random UT failures on loaded CI slaves.
      Also, for the WorkManager repair procedure, it requires to executed many times the operation to process all Works in failure.

        Attachments

          Issue Links

            Activity

              People

              • Votes:
                0 Vote for this issue
                Watchers:
                2 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved:

                  Time Tracking

                  Estimated:
                  Original Estimate - Not Specified
                  Not Specified
                  Remaining:
                  Remaining Estimate - 0 minutes
                  0m
                  Logged:
                  Time Spent - 5 hours
                  5h