@Test
public void testSetClusterInfo() throws Exception {

  String hdfsNameNode = "namenode001";
  int replicaFactor = 3;
  ClusterInfo clusterInfo = new ClusterInfo(hdfsNameNode, replicaFactor);
  when(zk.setData(eq("/" + CLUSTER_NAME), eq(clusterInfo.toJson()), anyInt()))
      .thenReturn(new Stat());
  zkManager.setClusterInfo(clusterInfo);
  verify(zk).setData(eq("/" + CLUSTER_NAME), eq(clusterInfo.toJson()), anyInt());
}