[SOLVED] job information not found in JobContext

job information not found in JobContext

I am running a Java program on a remote computer and trying to read the split data using RecordReader object but instead getting:

Exception in thread "main" java.io.IOException: job information not found in JobContext. HCatInputFormat.setInput() not called?

I already have called the following:

 _hcatInputFmt = HCatInputFormat.setInput(_myJob, db,tbl);

and then creating the RecordReader object as:

 _hcatInputFmt.createRecordReader(hSplit, taskContext)

On debugging it fails while searching for the value of the key: HCAT_KEY_JOB_INFO in job configuration object, while trying to create a RecordReader object.

How do I set this value? Any pointers will be helpful.

Thanks.

Solution

We have to use getConfiguration() method to get the configuration from the job object. The configuration object used in creating the job object won't do it.