@Test
public void testIsTopologyRefreshRequired() throws Exception {

  AmbariCustomCommandExecutionHelper helper = injector.getInstance(AmbariCustomCommandExecutionHelper.class);
  createClusterFixture("c2", "HDP-2.1.1", "c2");
  Assert.assertTrue(helper.isTopologyRefreshRequired("START", "c2", "HDFS"));
  Assert.assertTrue(helper.isTopologyRefreshRequired("RESTART", "c2", "HDFS"));
  Assert.assertFalse(helper.isTopologyRefreshRequired("STOP", "c2", "HDFS"));
}