Details
Description
In a few places in the ReplicationSource code calls terminate on itself which is a problem since in terminate() we wait on that thread to die.
In a few places in the ReplicationSource code calls terminate on itself which is a problem since in terminate() we wait on that thread to die.