conn=getConnection();
Iterator<Text> batchIterator = batches.iterator();
String jobIdString = jobId.toString();
jobId.set(jobIdString);
while (batchIterator.hasNext()) {
BatchResult result = conn.getBatchResult(jobIdString, batchIterator.next().toString());
batchResultText.set(result.toString());
logger.debug("Job Id " + jobIdString + " and Batch " + result);
context.write(jobId, batchResultText);
}
}
catch(Exception e) {