@Test
public void testSetNonExistingFileSetInfo() throws Exception {

  when(zk.exists(anyString(), anyBoolean())).thenReturn(null);
  when(zk.create(anyString(), any(byte[].class), anyListOf(ACL.class), any(CreateMode.class)))
      .thenReturn("");
  zkManager.setFileSetInfo(FILE_SET, FILE_SET_INFO);
  verify(zk).exists(eq(FILE_SET_PATH), eq(false));
  verify(zk).create(eq(FILE_SET_PATH), eq(FILE_SET_INFO.toJson()), anyListOf(ACL.class),
      any(CreateMode.class));
}