Revision 49532
Added by Tsampikos Livisianos almost 7 years ago
modules/dnet-openaire-stats/trunk/src/main/java/eu/dnetlib/data/mapreduce/hbase/statsExport/mapreduce/StatsMapper.java | ||
---|---|---|
89 | 89 |
oaf = UpdateMerger.mergeBodyUpdates(context, result.getFamilyMap(Bytes.toBytes(keyDecoder.getType().toString()))); |
90 | 90 |
|
91 | 91 |
} catch (Exception e) { |
92 |
/* |
|
92 | 93 |
System.err.println("Unable to parse proto in row: " + oaf.getEntity().getType().toString() + keyDecoder.getKey()); |
93 | 94 |
log.error("Unable to parse proto in row: " + oaf.getEntity().getType().toString() + keyDecoder.getKey(), e); |
95 |
*/ |
|
94 | 96 |
|
97 |
System.err.println("Unable to parse proto in row: " + keyDecoder.getKey()); |
|
98 |
log.error("Unable to parse proto in row: " + keyDecoder.getKey(), e); |
|
99 |
|
|
95 | 100 |
context.getCounter(ERROR_COUNTERS.rottenRecords).increment(1); |
96 | 101 |
} |
97 | 102 |
|
Also available in: Unified diff
replace error log