@Test
public void testGetClusterInfo() throws Exception {

  String hdfsNameNode = "namenode001";
  int replicaFactor = 3;
  ClusterInfo clusterInfo = new ClusterInfo(hdfsNameNode, replicaFactor);
  when(zk.getData(eq("/" + CLUSTER_NAME), anyBoolean(), any(Stat.class)))
      .thenReturn(clusterInfo.toJson());
  ClusterInfo returnedInfo = zkManager.getClusterInfo();
  assertEquals(hdfsNameNode, returnedInfo.hdfsNameNode);
  assertEquals(replicaFactor, returnedInfo.hdfsReplicationFactor);
}