Open mwacc opened 10 years ago
Hi there! it seems that "backend.parameters is deprecated."
I have mapreduce(input=COR_INPUT, output=COR_OUTPUT, input.format=make.input.format("csv", sep = ","), output.format=make.output.format("csv", sep = ","), map = my_mapper, reduce = my_reducer, backend.parameters = list(hadoop=list(D="mapred.task.timeout=3600000")))
but it doesn't work... So, how can I pass conf parameter mapred.task.timeout=3600000 to job?
Hi there! it seems that "backend.parameters is deprecated."
I have mapreduce(input=COR_INPUT, output=COR_OUTPUT, input.format=make.input.format("csv", sep = ","), output.format=make.output.format("csv", sep = ","), map = my_mapper, reduce = my_reducer, backend.parameters = list(hadoop=list(D="mapred.task.timeout=3600000")))
but it doesn't work... So, how can I pass conf parameter mapred.task.timeout=3600000 to job?