It¹s called from operator thread. The heartbeat queues it up for the operator thread to pick it up.
Do you have example of having race conditions (in which case it would be a bug not the design)? ‹ Chetan On 11/10/15, 10:31 AM, "Timothy Farkas" <[email protected]> wrote: >Why is committed called from the heart beat loop? Shouldn't it be called >from the main operator thread? I think this is inconsistent with the >contract provided for the rest of the callbacks. This is also causing race >conditions in some operators.
