[FLINK-6509] [tests] Perform TestingListener#waitForNewLeader under lock
Performin TestingListener#waitForNewLeader under the lock which is also hold when updating the leader information makes sure that leader changes won't go unnoticed. This led before to failing test cases due to timeouts. This closes #3853.
Showing
想要评论请 注册 或 登录