search

linkedin / brooklin

An extensible distributed system for reliable nearline data streaming at scale
BSD 2-Clause "Simplified" License
922 stars 137 forks source link

Apply lock at Coordinator class level #979

Closed hshukla closed 10 months ago

hshukla commented 10 months ago

As part of https://github.com/linkedin/brooklin/pull/975 where we used 

synchronized (this) {...}

it was giving lock on the CoordinatorEventProcessor instance. However, we need a lock on the Coordinator class, hence the notifyAll was not working as expected.

This PR fixes the above regression by introducing 

synchronized (Coordinator.class) {