-
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
-
Epic Link:
-
Tags:
-
Sprint:nxplatform 11.1.13
-
Story Points:2
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.
- is related to
-
NXP-27148 Store Work in failure in DLQ for repair purpose
- Resolved