configuration.setBoolean("mapred.map.tasks.speculative.execution", false); configuration.setBoolean("mapred.reduce.tasks.speculative.execution", false);How to set notification url?
configuration.set("job.end.notification.url", request.getNotificationUrl());How to attach all required jars to the job? configuration.set("tmpjars", StringUtils.join(request.getJars(), ","));
Brak komentarzy:
Prześlij komentarz