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

Reply via email to