java - (JAVA) 如何查看AWS EMR中Step的状态？

Question

我正在使用 Java EMR API 在 EMR 集群上运行 pig 作业。我正在使用以下代码在 JobFLow 中添加步骤:

    String jobFlowId = "j-assdasd";
    AmazonElasticMapReduceClient client = new AmazonElasticMapReduceClient(
                    credentials);

    StepFactory stepFactory = new StepFactory();


    StepConfig executePig = new StepConfig()
                    .withName("Execute Pig")
                    .withActionOnFailure(ActionOnFailure.CANCEL_AND_WAIT)
                    .withHadoopJarStep(
                                    stepFactory
                                    .newRunPigScriptStep("s3://bucket/script/load.pig"));

    AddJobFlowStepsRequest pig = new AddJobFlowStepsRequest(jobFlowId)
                    .withSteps( executePig);
    AddJobFlowStepsResult result = client.addJobFlowSteps(pig);

如何获取“Execute Pig”状态？我想让程序等到 EMR 上的步骤完成。

Answer 1

我找到了一种方法 java:

   List<String> id = result.getStepIds();
   DescribeStepResult res = client.describeStep(new DescribeStepRequest().withStepId(id.get(0)));
   StepStatus status = res.getStep().getStatus();
   String stas = status.getState();

但是，这里我们需要循环状态直到它返回完成。