У меня есть проблемы запуска на карту-свертке Java приложении я упростил мою проблему с помощью кода учебника дал от AWS, который работает предопределенный шаг:AWS ОЙ ошибка проверки
public class Main {
public static void main(String[] args) {
AWSCredentials credentials = getCredentials();
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());
RunJobFlowRequest request = new RunJobFlowRequest()
.withName("Hive Interactive")
.withAmiVersion("3.3.1")
.withSteps(enabledebugging, installHive)
.withLogUri("s3://tweets-hadoop/")
.withServiceRole("service_role")
.withJobFlowRole("jobflow_role")
.withInstances(
new JobFlowInstancesConfig().withEc2KeyName("hadoop")
.withInstanceCount(5)
.withKeepJobFlowAliveWhenNoSteps(true)
.withMasterInstanceType("m3.xlarge")
.withSlaveInstanceType("m1.large"));
RunJobFlowResult result = emr.runJobFlow(request);
System.out.println(result);
}
private static AWSCredentials getCredentials() {
AWSCredentials credentials = null;
credentials = new BasicAWSCredentials("<KEY>","<VALUE>");
return credentials;
}
}
где, являются секретным активным ключом, а «hadoop» - это ключевая пара, созданная в консоли EC2.
После запуска я вижу работу, пытаясь запустить в консоли ЭМИ, через 1 минуту она меняется от «начиная с» к «Прекращено с ошибками Проверка ошибок»
никакой другой информации
Любые идеи, что пошло не так?
Спасибо!
Дополнительные сведения см. В папке журнала EMR на S3, которую вы настроили. В качестве первого шага выполните следующие шаги, описанные в учебнике http://docs.aws.amazon.com/ElasticMapReduce/latest/DeveloperGuide/gsg-launch-cluster.html. – user1452132