Hi
I'm running an uploader to Hbase using mapreduce and in the map
configure method I use:
public void configure(JobConf job) {
mapTaskId = job.get("mapred.task.id");
inputFile = job.get("mapred.input.file");
custId="";
if (inputFile!=null) {
String splits[] = inputFile.split("_");
if (splits.length > 2)
custId = splits[1];
}
}
I get the mapTaskId correctly but am getting null inputFile.
I previously set
public JobConf createSubmittableJob(String[] args) {
JobConf c = new JobConf(getConf(), ClogUploader.class);
FileInputFormat.setInputPaths(c, new Path(args[0]));
}
Any suggestions?
Thanks
-Yair