@Test
public void testStart() throws InterruptedException {

    ClusterSyncManager clusterSyncManager = new ClusterSyncManager(STREAMING.ZK_CLUSTER_MANAGER_PATH, "id",
            configurationContext, failOverTask,curatorFramework, zkUtils, clusterBarrierManager);
    doNothing().when(curatorFramework).start();
    when(curatorFramework.getZookeeperClient().blockUntilConnectedOrTimedOut()).thenReturn(true);
}