本文整理了Java中org.finra.herd.dao.helper.XmlHelper.unmarshallXmlToObject()方法的一些代码示例，展示了XmlHelper.unmarshallXmlToObject()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。XmlHelper.unmarshallXmlToObject()方法的具体详情如下：
包路径：org.finra.herd.dao.helper.XmlHelper
类名称：XmlHelper
方法名：unmarshallXmlToObject

XmlHelper.unmarshallXmlToObject介绍

[英]Unmarshalls the xml into JAXB object.
[中]将xml解组为JAXB对象。

代码示例

代码示例来源：origin: FINRAOS/herd

/**
 * A test case to validate that the XSD restrictions are loose enough to allow empty elements for nested elements.
 */
@Test
public void testUnmarshallXmlWithNestedElements() throws JAXBException
{
  String xml = "<emrClusterCreateRequest>" + "<namespace>" + NAMESPACE + "</namespace>" + "<emrClusterDefinitionName>" + EMR_CLUSTER_DEFINITION_NAME +
    "</emrClusterDefinitionName>" + "<emrClusterName>cluster1</emrClusterName>" + "<dryRun>true</dryRun>" + "<emrClusterDefinitionOverride>" +
    "<customBootstrapActionMaster/>" + "<customBootstrapActionAll/>" + "<instanceDefinitions/>" + "<nodeTags/>" + "<daemonConfigurations/>" +
    "<hadoopConfigurations/>" + "</emrClusterDefinitionOverride>" + "</emrClusterCreateRequest>";
  xmlHelper.unmarshallXmlToObject(EmrClusterCreateRequest.class, xml);
}

代码示例来源：origin: FINRAOS/herd

/**
 * Loads from the specified XML file and returns a test EMR cluster definition configuration.
 *
 * @param xmlFileClasspath the XML file classpath to be loaded
 *
 * @return the newly created EMR cluster definition configuration instance
 */
private EmrClusterDefinition getTestEmrClusterDefinitionConfiguration(String xmlFileClasspath) throws Exception
{
  String xmlString = getTestEmrClusterDefinitionConfigurationXml(xmlFileClasspath);
  return xmlHelper.unmarshallXmlToObject(EmrClusterDefinition.class, xmlString);
}

代码示例来源：origin: FINRAOS/herd

@Test
public void testGetXmlClobPropertyAndUnmarshallToObject() throws JAXBException
{
  // Create a mock configuration entity.
  ConfigurationEntity configurationEntity = mock(ConfigurationEntity.class);
  when(configurationEntity.getValueClob()).thenReturn(CONFIGURATION_VALUE);
  // Mock the external calls.
  when(configurationDao.getConfigurationByKey(CONFIGURATION_KEY)).thenReturn(configurationEntity);
  when(xmlHelper.unmarshallXmlToObject(String.class, CONFIGURATION_VALUE)).thenReturn(STRING_VALUE);
  // Call the method under test.
  String result = configurationDaoHelper.getXmlClobPropertyAndUnmarshallToObject(String.class, CONFIGURATION_KEY);
  // Verify the external calls.
  verify(configurationDao).getConfigurationByKey(CONFIGURATION_KEY);
  verify(xmlHelper).unmarshallXmlToObject(String.class, CONFIGURATION_VALUE);
  verifyNoMoreInteractionsHelper();
  // Validate the results.
  assertEquals(STRING_VALUE, result);
}

代码示例来源：origin: FINRAOS/herd

@Test
public void testUnmarshallXmlToObject() throws Exception
{
  assertEquals(getTestBuildInformation(), xmlHelper.unmarshallXmlToObject(BuildInformation.class, getTestXml()));
}

代码示例来源：origin: FINRAOS/herd

/**
 * This method tests the error cases for AmazonExceptions for Illegal Argument
 */
@Test(expected = ObjectNotFoundException.class)
public void testCreateEmrClusterAmazonObjectNotFound() throws Exception
{
  // Create the namespace entity.
  NamespaceEntity namespaceEntity = namespaceDaoTestHelper.createNamespaceEntity(NAMESPACE);
  String configXml = IOUtils.toString(resourceLoader.getResource(EMR_CLUSTER_DEFINITION_XML_FILE_MINIMAL_CLASSPATH).getInputStream());
  EmrClusterDefinition emrClusterDefinition = xmlHelper.unmarshallXmlToObject(EmrClusterDefinition.class, configXml);
  emrClusterDefinition.setAmiVersion(MockAwsOperationsHelper.AMAZON_NOT_FOUND);
  configXml = xmlHelper.objectToXml(emrClusterDefinition);
  emrClusterDefinitionDaoTestHelper.createEmrClusterDefinitionEntity(namespaceEntity, EMR_CLUSTER_DEFINITION_NAME, configXml);
  // Create a new EMR cluster create request.
  EmrClusterCreateRequest request = getNewEmrClusterCreateRequest();
  emrService.createCluster(request);
}

代码示例来源：origin: FINRAOS/herd

/**
 * This method tests additionalInfo
 */
@Test
public void testCreateEmrClusterAdditionalInfo() throws Exception
{
  // Create the namespace entity.
  NamespaceEntity namespaceEntity = namespaceDaoTestHelper.createNamespaceEntity(NAMESPACE);
  String configXml = IOUtils.toString(resourceLoader.getResource(EMR_CLUSTER_DEFINITION_XML_FILE_MINIMAL_CLASSPATH).getInputStream());
  EmrClusterDefinition emrClusterDefinition = xmlHelper.unmarshallXmlToObject(EmrClusterDefinition.class, configXml);
  // Set the additional Info
  emrClusterDefinition
    .setAdditionalInfo("{ami64: \"ami-e82af080\", amiHvm64: \"ami-e82af080\", hadoopVersion: \"2.4.0\", hadoopConfigurationVersion: \"3.1\"}");
  configXml = xmlHelper.objectToXml(emrClusterDefinition);
  emrClusterDefinitionDaoTestHelper.createEmrClusterDefinitionEntity(namespaceEntity, EMR_CLUSTER_DEFINITION_NAME, configXml);
  // Create a new EMR cluster create request.
  EmrClusterCreateRequest request = getNewEmrClusterCreateRequest();
  emrService.createCluster(request);
}

代码示例来源：origin: FINRAOS/herd

/**
 * This method tests the error cases for AmazonExceptions for Illegal Argument
 */
@Test(expected = IllegalArgumentException.class)
public void testCreateEmrClusterAmazonBadRequest() throws Exception
{
  // Create the namespace entity.
  NamespaceEntity namespaceEntity = namespaceDaoTestHelper.createNamespaceEntity(NAMESPACE);
  String configXml = IOUtils.toString(resourceLoader.getResource(EMR_CLUSTER_DEFINITION_XML_FILE_MINIMAL_CLASSPATH).getInputStream());
  EmrClusterDefinition emrClusterDefinition = xmlHelper.unmarshallXmlToObject(EmrClusterDefinition.class, configXml);
  emrClusterDefinition.setAmiVersion(MockAwsOperationsHelper.AMAZON_BAD_REQUEST);
  configXml = xmlHelper.objectToXml(emrClusterDefinition);
  emrClusterDefinitionDaoTestHelper.createEmrClusterDefinitionEntity(namespaceEntity, EMR_CLUSTER_DEFINITION_NAME, configXml);
  // Create a new EMR cluster create request.
  EmrClusterCreateRequest request = getNewEmrClusterCreateRequest();
  emrService.createCluster(request);
}

代码示例来源：origin: FINRAOS/herd

/**
 * This method tests the error cases for AmazonExceptions for AmazonServiceException
 */
@Test(expected = AmazonServiceException.class)
public void testCreateEmrClusterAmazonOtherException() throws Exception
{
  // Create the namespace entity.
  NamespaceEntity namespaceEntity = namespaceDaoTestHelper.createNamespaceEntity(NAMESPACE);
  String configXml = IOUtils.toString(resourceLoader.getResource(EMR_CLUSTER_DEFINITION_XML_FILE_MINIMAL_CLASSPATH).getInputStream());
  EmrClusterDefinition emrClusterDefinition = xmlHelper.unmarshallXmlToObject(EmrClusterDefinition.class, configXml);
  emrClusterDefinition.setAmiVersion(MockAwsOperationsHelper.AMAZON_SERVICE_EXCEPTION);
  configXml = xmlHelper.objectToXml(emrClusterDefinition);
  emrClusterDefinitionDaoTestHelper.createEmrClusterDefinitionEntity(namespaceEntity, EMR_CLUSTER_DEFINITION_NAME, configXml);
  // Create a new EMR cluster create request.
  EmrClusterCreateRequest request = getNewEmrClusterCreateRequest();
  emrService.createCluster(request);
}

代码示例来源：origin: FINRAOS/herd

/**
 * This method tests supported product
 */
@Test
public void testCreateEmrClusterSupportedProduct() throws Exception
{
  // Create the namespace entity.
  NamespaceEntity namespaceEntity = namespaceDaoTestHelper.createNamespaceEntity(NAMESPACE);
  String configXml = IOUtils.toString(resourceLoader.getResource(EMR_CLUSTER_DEFINITION_XML_FILE_MINIMAL_CLASSPATH).getInputStream());
  EmrClusterDefinition emrClusterDefinition = xmlHelper.unmarshallXmlToObject(EmrClusterDefinition.class, configXml);
  // Set the supported product
  emrClusterDefinition.setSupportedProduct("mapr-m3");
  configXml = xmlHelper.objectToXml(emrClusterDefinition);
  emrClusterDefinitionDaoTestHelper.createEmrClusterDefinitionEntity(namespaceEntity, EMR_CLUSTER_DEFINITION_NAME, configXml);
  // Create a new EMR cluster create request.
  EmrClusterCreateRequest request = getNewEmrClusterCreateRequest();
  emrService.createCluster(request);
}

代码示例来源：origin: FINRAOS/herd

@Test
public void testCreateEmrClusterSecurityConfigurationReleaseLabelWithPrefix() throws Exception
{
  // Create the namespace entity.
  NamespaceEntity namespaceEntity = namespaceDaoTestHelper.createNamespaceEntity(NAMESPACE);
  String configXml = IOUtils.toString(resourceLoader.getResource(EMR_CLUSTER_DEFINITION_XML_FILE_MINIMAL_CLASSPATH).getInputStream());
  EmrClusterDefinition emrClusterDefinition = xmlHelper.unmarshallXmlToObject(EmrClusterDefinition.class, configXml);
  // Set the security configuration along with the EMR release label starting with an "emr-" prefix.
  // This is needed since security configuration is not supported prior to EMR version 4.8.0.
  emrClusterDefinition.setSecurityConfiguration("securityConfiguration");
  emrClusterDefinition.setReleaseLabel("emr-4.8.0");
  configXml = xmlHelper.objectToXml(emrClusterDefinition);
  emrClusterDefinitionDaoTestHelper.createEmrClusterDefinitionEntity(namespaceEntity, EMR_CLUSTER_DEFINITION_NAME, configXml);
  // Create a new EMR cluster create request.
  EmrClusterCreateRequest request = getNewEmrClusterCreateRequest();
  emrService.createCluster(request);
}

代码示例来源：origin: FINRAOS/herd

/**
 * This method tests the service IAM role
 */
@Test
public void testCreateEmrClusterServiceRole() throws Exception
{
  // Create the namespace entity.
  NamespaceEntity namespaceEntity = namespaceDaoTestHelper.createNamespaceEntity(NAMESPACE);
  String configXml = IOUtils.toString(resourceLoader.getResource(EMR_CLUSTER_DEFINITION_XML_FILE_WITH_CLASSPATH).getInputStream());
  EmrClusterDefinition emrClusterDefinition = xmlHelper.unmarshallXmlToObject(EmrClusterDefinition.class, configXml);
  emrClusterDefinition.setServiceIamRole(emrClusterDefinition.getEc2NodeIamProfileName());
  configXml = xmlHelper.objectToXml(emrClusterDefinition);
  emrClusterDefinitionDaoTestHelper.createEmrClusterDefinitionEntity(namespaceEntity, EMR_CLUSTER_DEFINITION_NAME, configXml);
  // Create a new EMR cluster create request.
  EmrClusterCreateRequest request = getNewEmrClusterCreateRequest();
  emrService.createCluster(request);
}

代码示例来源：origin: FINRAOS/herd

/**
 * This method tests security configuration.
 */
@Test
public void testCreateEmrClusterSecurityConfiguration() throws Exception
{
  // Create the namespace entity.
  NamespaceEntity namespaceEntity = namespaceDaoTestHelper.createNamespaceEntity(NAMESPACE);
  String configXml = IOUtils.toString(resourceLoader.getResource(EMR_CLUSTER_DEFINITION_XML_FILE_MINIMAL_CLASSPATH).getInputStream());
  EmrClusterDefinition emrClusterDefinition = xmlHelper.unmarshallXmlToObject(EmrClusterDefinition.class, configXml);
  // Set the security configuration along with the EMR release label.
  // This is needed since security configuration is not supported prior to EMR version 4.8.0.
  emrClusterDefinition.setSecurityConfiguration("securityConfiguration");
  emrClusterDefinition.setReleaseLabel("4.8.0");
  configXml = xmlHelper.objectToXml(emrClusterDefinition);
  emrClusterDefinitionDaoTestHelper.createEmrClusterDefinitionEntity(namespaceEntity, EMR_CLUSTER_DEFINITION_NAME, configXml);
  // Create a new EMR cluster create request.
  EmrClusterCreateRequest request = getNewEmrClusterCreateRequest();
  emrService.createCluster(request);
}

代码示例来源：origin: FINRAOS/herd

@Test
public void testCreateEmrClusterSecurityConfigurationNoReleaseLabel() throws Exception
{
  // Create the namespace entity.
  NamespaceEntity namespaceEntity = namespaceDaoTestHelper.createNamespaceEntity(NAMESPACE);
  String configXml = IOUtils.toString(resourceLoader.getResource(EMR_CLUSTER_DEFINITION_XML_FILE_MINIMAL_CLASSPATH).getInputStream());
  EmrClusterDefinition emrClusterDefinition = xmlHelper.unmarshallXmlToObject(EmrClusterDefinition.class, configXml);
  // Set the security configuration without an EMR release label.
  emrClusterDefinition.setSecurityConfiguration("securityConfiguration");
  emrClusterDefinition.setReleaseLabel(BLANK_TEXT);
  configXml = xmlHelper.objectToXml(emrClusterDefinition);
  emrClusterDefinitionDaoTestHelper.createEmrClusterDefinitionEntity(namespaceEntity, EMR_CLUSTER_DEFINITION_NAME, configXml);
  // Try to create a new EMR cluster.
  try
  {
    emrService.createCluster(getNewEmrClusterCreateRequest());
  }
  catch (IllegalArgumentException e)
  {
    assertEquals("EMR security configuration is not supported prior to EMR release 4.8.0.", e.getMessage());
  }
}

代码示例来源：origin: FINRAOS/herd

@Test
public void testCreateEmrClusterWithAccountIdAccountNoExists() throws Exception
{
  // Create the namespace entity.
  NamespaceEntity namespaceEntity = namespaceDaoTestHelper.createNamespaceEntity(NAMESPACE);
  String definitionXml = IOUtils.toString(resourceLoader.getResource(EMR_CLUSTER_DEFINITION_XML_FILE_WITH_CLASSPATH).getInputStream());
  EmrClusterDefinition expectedEmrClusterDefinition = xmlHelper.unmarshallXmlToObject(EmrClusterDefinition.class, definitionXml);
  emrClusterDefinitionDaoTestHelper.createEmrClusterDefinitionEntity(namespaceEntity, EMR_CLUSTER_DEFINITION_NAME, definitionXml);
  // Create a new EMR cluster create request and add an account id to the EMR cluster definition override.
  EmrClusterCreateRequest emrClusterCreateRequest = getNewEmrClusterCreateRequestWithAccountId();
  EmrClusterDefinition emrClusterDefinitionOverride = new EmrClusterDefinition();
  emrClusterCreateRequest.setEmrClusterDefinitionOverride(emrClusterDefinitionOverride);
  emrClusterDefinitionOverride.setAccountId(AWS_ACCOUNT_ID);
  // Try to create an EMR cluster using a non-existing AWS account.
  try
  {
    emrService.createCluster(emrClusterCreateRequest);
  }
  catch (ObjectNotFoundException e)
  {
    assertEquals(String.format("Trusting AWS account with id \"%s\" doesn't exist.", AWS_ACCOUNT_ID), e.getMessage());
  }
}

代码示例来源：origin: FINRAOS/herd

/**
   * Creates the EMR cluster definition information from the persisted entity.
   *
   * @param emrClusterDefinitionEntity the EMR cluster definition entity
   *
   * @return the EMR cluster definition information
   */
  private EmrClusterDefinitionInformation createEmrClusterDefinitionFromEntity(EmrClusterDefinitionEntity emrClusterDefinitionEntity) throws Exception
  {
    // Unmarshal EMR cluster definition XML into JAXB object.
    EmrClusterDefinition emrClusterDefinition = xmlHelper.unmarshallXmlToObject(EmrClusterDefinition.class, emrClusterDefinitionEntity.getConfiguration());

    // Create a new instance of EMR cluster definition information.
    EmrClusterDefinitionInformation emrClusterDefinitionInformation = new EmrClusterDefinitionInformation();

    emrClusterDefinitionInformation.setId(emrClusterDefinitionEntity.getId());
    emrClusterDefinitionInformation
      .setEmrClusterDefinitionKey(new EmrClusterDefinitionKey(emrClusterDefinitionEntity.getNamespace().getCode(), emrClusterDefinitionEntity.getName()));
    emrClusterDefinitionInformation.setEmrClusterDefinition(emrClusterDefinition);

    return emrClusterDefinitionInformation;
  }
}

代码示例来源：origin: org.finra.herd/herd-service

/**
   * Creates the EMR cluster definition information from the persisted entity.
   *
   * @param emrClusterDefinitionEntity the EMR cluster definition entity
   *
   * @return the EMR cluster definition information
   */
  private EmrClusterDefinitionInformation createEmrClusterDefinitionFromEntity(EmrClusterDefinitionEntity emrClusterDefinitionEntity) throws Exception
  {
    // Unmarshal EMR cluster definition XML into JAXB object.
    EmrClusterDefinition emrClusterDefinition = xmlHelper.unmarshallXmlToObject(EmrClusterDefinition.class, emrClusterDefinitionEntity.getConfiguration());

    // Create a new instance of EMR cluster definition information.
    EmrClusterDefinitionInformation emrClusterDefinitionInformation = new EmrClusterDefinitionInformation();

    emrClusterDefinitionInformation.setId(emrClusterDefinitionEntity.getId());
    emrClusterDefinitionInformation
      .setEmrClusterDefinitionKey(new EmrClusterDefinitionKey(emrClusterDefinitionEntity.getNamespace().getCode(), emrClusterDefinitionEntity.getName()));
    emrClusterDefinitionInformation.setEmrClusterDefinition(emrClusterDefinition);

    return emrClusterDefinitionInformation;
  }
}

代码示例来源：origin: FINRAOS/herd

@Test
public void testGetActiveEmrClusterByName() throws Exception
{
  // Get the EMR cluster definition object
  String configXml = IOUtils.toString(resourceLoader.getResource(EMR_CLUSTER_DEFINITION_XML_FILE_WITH_CLASSPATH).getInputStream());
  EmrClusterDefinition emrClusterDefinition = xmlHelper.unmarshallXmlToObject(EmrClusterDefinition.class, configXml);
  // check cluster summary before creation
  ClusterSummary clusterSummary = emrDao.getActiveEmrClusterByName(MockEmrOperationsImpl.MOCK_CLUSTER_NAME, emrHelper.getAwsParamsDto());
  assertNull(clusterSummary);
  // Create the cluster
  String clusterId = emrDao.createEmrCluster(MockEmrOperationsImpl.MOCK_CLUSTER_NAME, emrClusterDefinition, emrHelper.getAwsParamsDto());
  // check cluster summary after creation
  clusterSummary = emrDao.getActiveEmrClusterByName(MockEmrOperationsImpl.MOCK_CLUSTER_NAME, emrHelper.getAwsParamsDto());
  assertNotNull(clusterSummary);
  assertEquals(clusterId, clusterSummary.getId());
}

代码示例来源：origin: FINRAOS/herd

@Test
public void testCreateEmrClusterWithSecurityGroups() throws Exception
{
  // Create the namespace entity.
  NamespaceEntity namespaceEntity = namespaceDaoTestHelper.createNamespaceEntity(NAMESPACE);
  // Retrieve the EMR cluster definition.
  String configXml = IOUtils.toString(resourceLoader.getResource(EMR_CLUSTER_DEFINITION_XML_FILE_WITH_CLASSPATH).getInputStream());
  EmrClusterDefinition emrClusterDefinition = xmlHelper.unmarshallXmlToObject(EmrClusterDefinition.class, configXml);
  // Update the EMR cluster definition to use instance fleets instead of instance group definitions.
  emrClusterDefinition.setMasterSecurityGroup(EMR_MASTER_SECURITY_GROUP);
  emrClusterDefinition.setSlaveSecurityGroup(EMR_SLAVE_SECURITY_GROUP);
  // Create an entity for the the updated EMR cluster definition.
  configXml = xmlHelper.objectToXml(emrClusterDefinition);
  emrClusterDefinitionDaoTestHelper.createEmrClusterDefinitionEntity(namespaceEntity, EMR_CLUSTER_DEFINITION_NAME, configXml);
  // Create a new EMR cluster create request.
  EmrClusterCreateRequest request = getNewEmrClusterCreateRequest();
  EmrCluster emrCluster = emrService.createCluster(request);
  // Validate the returned object against the input.
  assertNotNull(emrCluster);
  assertTrue(emrCluster.getNamespace().equals(request.getNamespace()));
  assertTrue(emrCluster.getEmrClusterDefinition().getMasterSecurityGroup().equals(EMR_MASTER_SECURITY_GROUP));
  assertTrue(emrCluster.getEmrClusterDefinition().getSlaveSecurityGroup().equals(EMR_SLAVE_SECURITY_GROUP));
}

代码示例来源：origin: FINRAOS/herd

@Test
public void testCreateEmrClusterOverrideExistingCoreInstanceToNullAssertSuccess() throws Exception
{
  // Create the namespace entity.
  NamespaceEntity namespaceEntity = namespaceDaoTestHelper.createNamespaceEntity(NAMESPACE);
  String definitionXml = IOUtils.toString(resourceLoader.getResource(EMR_CLUSTER_DEFINITION_XML_FILE_WITH_CLASSPATH).getInputStream());
  EmrClusterDefinition emrClusterDefinition = xmlHelper.unmarshallXmlToObject(EmrClusterDefinition.class, definitionXml);
  emrClusterDefinition.getInstanceDefinitions().getCoreInstances().setInstanceCount(1);
  emrClusterDefinitionDaoTestHelper
    .createEmrClusterDefinitionEntity(namespaceEntity, EMR_CLUSTER_DEFINITION_NAME, xmlHelper.objectToXml(emrClusterDefinition));
  // Create a new EMR cluster create request
  EmrClusterCreateRequest request = getNewEmrClusterCreateRequest();
  EmrClusterDefinition emrClusterDefinitionOverride = new EmrClusterDefinition();
  emrClusterDefinitionOverride.setInstanceDefinitions(emrClusterDefinition.getInstanceDefinitions());
  emrClusterDefinitionOverride.getInstanceDefinitions().setCoreInstances(null);
  request.setEmrClusterDefinitionOverride(emrClusterDefinitionOverride);
  EmrCluster emrClusterCreateResponse = emrService.createCluster(request);
  assertNull(emrClusterCreateResponse.getEmrClusterDefinition().getInstanceDefinitions().getCoreInstances());
}

代码示例来源：origin: FINRAOS/herd

@Test
public void testCreateEmrClusterOverrideExistingCoreInstanceTo0InstanceCountAssertSuccess() throws Exception
{
  // Create the namespace entity.
  NamespaceEntity namespaceEntity = namespaceDaoTestHelper.createNamespaceEntity(NAMESPACE);
  String definitionXml = IOUtils.toString(resourceLoader.getResource(EMR_CLUSTER_DEFINITION_XML_FILE_WITH_CLASSPATH).getInputStream());
  EmrClusterDefinition emrClusterDefinition = xmlHelper.unmarshallXmlToObject(EmrClusterDefinition.class, definitionXml);
  emrClusterDefinition.getInstanceDefinitions().getCoreInstances().setInstanceCount(1);
  emrClusterDefinitionDaoTestHelper
    .createEmrClusterDefinitionEntity(namespaceEntity, EMR_CLUSTER_DEFINITION_NAME, xmlHelper.objectToXml(emrClusterDefinition));
  // Create a new EMR cluster create request
  EmrClusterCreateRequest request = getNewEmrClusterCreateRequest();
  EmrClusterDefinition emrClusterDefinitionOverride = new EmrClusterDefinition();
  emrClusterDefinitionOverride.setInstanceDefinitions(emrClusterDefinition.getInstanceDefinitions());
  emrClusterDefinitionOverride.getInstanceDefinitions().getCoreInstances().setInstanceCount(0);
  request.setEmrClusterDefinitionOverride(emrClusterDefinitionOverride);
  EmrCluster emrClusterCreateResponse = emrService.createCluster(request);
  assertNull(emrClusterCreateResponse.getEmrClusterDefinition().getInstanceDefinitions().getCoreInstances());
}