diff --git a/digdag-standards/src/main/java/io/digdag/standards/operator/aws/EmrOperatorFactory.java b/digdag-standards/src/main/java/io/digdag/standards/operator/aws/EmrOperatorFactory.java index da23f8ebc2..2784ab3bd4 100644 --- a/digdag-standards/src/main/java/io/digdag/standards/operator/aws/EmrOperatorFactory.java +++ b/digdag-standards/src/main/java/io/digdag/standards/operator/aws/EmrOperatorFactory.java @@ -395,7 +395,7 @@ private Optional checkStepCompletion(AmazonElasticMapReduce emr, Submissio details != null ? details : "{}"); } - throw new TaskExecutionException("EMR job failed", ConfigElement.empty()); + throw new TaskExecutionException("EMR job failed"); case "COMPLETED": logger.info("EMR steps done"); @@ -519,7 +519,7 @@ private Optional checkClusterBootStatus(AmazonElasticMapReduce emr, NewC if (createOnly) { // TODO: log more information about the errors // TODO: inspect state change reason to figure out whether it was the boot that failed or e.g. steps submitted by another agent - throw new TaskExecutionException("EMR boot failed: " + cluster.id(), ConfigElement.empty()); + throw new TaskExecutionException("EMR boot failed: " + cluster.id()); } return Optional.of(clusterState);