Details
-
Improvement
-
Status: Resolved
-
P2
-
Resolution: Fixed
-
None
-
None
Description
Currently in WorkerCustomSources.java it is hard-coded to 10 seconds, 10k elements, with 1sec waiting for elements if none are available.
There are cases where it would be beneficial to wait longer and process more data so it would be nice if this was controlled by pipeline option.
Attachments
Issue Links
- links to