Details
-
Bug
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
None
-
None
-
None
-
None
Description
Samza supports two types of run loop - synchronous and asynchronous. Fairness is guaranteed in synchronous run loop where commit, window, process gets called in round robin fashion. The asynchronous run loop has the potential for starvation if we have window trigger interval <<< time taken to execute code within window method.
We need to warn users about this potential starvation and fix the guarantee between window, process, commit methods in AsyncRunLoop.
Attachments
Issue Links
- links to
