} finally {
if(getRecordReader() != null) {
getRecordReader().close();
}
}
<BUG>}
postLoad(context);</BUG>
LOG.info("Load {} records.", count);
<BUG>LOG.info("Data loading time:{}ms", TimeUnit.NANOSECONDS.toMillis(System.nanoTime() - start));
</BUG>
}

} finally {
if(getRecordReader() != null) {
getRecordReader().close();
}
}
}
if(count == 0L) {
throw new IllegalStateException(
"Record account in such worker is zero, please check if any exceptions in your input data.");
}
postLoad(context);
LOG.info("Load {} records.", count);
LOG.info("Data loading time: {}ms", TimeUnit.NANOSECONDS.toMillis(System.nanoTime() - start));
}
