@Test
public void testInitializedNodeStatusShouldBeGroupInitialize() throws Exception {

    when(configurationContext.isClusteringEnabled()).thenReturn(false);
    clusterSyncManager = new ClusterSyncManager(STREAMING.ZK_CLUSTER_MANAGER_PATH, "id",
            configurationContext, failOverTask,curatorFramework, zkUtils, clusterBarrierManager);
    String nodeStatusPath = clusterSyncManager.initializedNodeStatus();
    assertNotNull(nodeStatusPath);
    assertEquals(STREAMING.ZK_EPHEMERAL_NODE_STATUS_PATH,nodeStatusPath);
}