Details
-
Improvement
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
None
-
None
-
None
-
None
Description
The current implementation of 'creating intermediate streams' depends on leader election, followed by the leader creating the intermediate streams. We have removed this dependency on leader election and changed the Latch interface to a generic Lock interface. Following this, any processor that acquires the lock can create the intermediate streams, irrespective of whether it is the leader or not. It releases the lock after successful creation of the streams.
Attachments
Issue Links
- links to
