Search code examples
hadoophivehcatalog

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.