Skip to content

Commit

Permalink
emr: fix empty error message
Browse files Browse the repository at this point in the history
  • Loading branch information
frsyuki committed Jan 7, 2017
1 parent f8babb6 commit 3ecd1b9
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -395,7 +395,7 @@ private Optional<Step> 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");
Expand Down Expand Up @@ -519,7 +519,7 @@ private Optional<String> 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);

Expand Down

0 comments on commit 3ecd1b9

Please sign in to comment.