Настройка ОЙ с помощью AWS Java SDK

Question

Ниже мой код для установки ОГО кластера:

public void createCluster(){ 
     AWSCredentials credentials = new BasicAWSCredentials("xxx","xxx"); 
     AmazonElasticMapReduceClient emr = new AmazonElasticMapReduceClient(credentials); 

     StepFactory stepFactory = new StepFactory(); 

     StepConfig enableDebugging = new StepConfig() 
      .withName("Enable Debugging") 
      .withActionOnFailure("TERMINATE_JOB_FLOW") 
      .withHadoopJarStep(stepFactory.newEnableDebuggingStep()); 

     StepConfig installHive = new StepConfig() 
      .withName("Install Hive") 
      .withActionOnFailure("TERMINATE_JOB_FLOW") 
      .withHadoopJarStep(stepFactory.newInstallHiveStep()); 

     /* StepConfig hiveScript = new StepConfig().withName("Hive Script") 
      .withActionOnFailure("TERMINATE_JOB_FLOW") 
      .withHadoopJarStep(stepFactory.newRunHiveScriptStep("s3://mywordcountbuckett/binary/WordCount.jar")); 
      */ 

     RunJobFlowRequest request = new RunJobFlowRequest() 
      .withName("Hive Interactive") 
      .withAmiVersion("3.8") 
      .withSteps(enableDebugging, installHive) 

      .withLogUri("s3://mywordcountbuckett/") 
      .withServiceRole("EMR_DefaultRole") 
      .withJobFlowRole("EMR_EC2_DefaultRole") 
      .withInstances(new JobFlowInstancesConfig() 
       .withEc2KeyName("mykeypair") 
       .withInstanceCount(5) 
       .withKeepJobFlowAliveWhenNoSteps(true) 
       .withMasterInstanceType("m3.xlarge") 
       .withSlaveInstanceType("m1.large")); 

     RunJobFlowResult result = emr.runJobFlow(request); 
     System.out.println("This is result: " + result.toString()); 

В Println печатает это:

This is result: {JobFlowId: j-10BX80MGWF3XQ} 

Означает ли это, я успешно создан кластер? Однако, когда я пытался просмотреть с aws.amazon.com, кластера не было создано.

И ничего не было создано в EC2.

Answer 1

Это проблема региона.

Размещенные этот код и все работало соответственно:

emr.setRegion(Region.getRegion(Regions.US_WEST_2));