You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@gora.apache.org by le...@apache.org on 2014/01/08 02:01:51 UTC
svn commit: r1556417 - in /gora/branches/GORA_94: CHANGES.txt
gora-core/src/main/java/org/apache/gora/mapreduce/GoraRecordWriter.java
Author: lewismc
Date: Wed Jan 8 01:01:51 2014
New Revision: 1556417
URL: http://svn.apache.org/r1556417
Log:
GORA-285 Change logging at o.a.g.mapreduce.GoraRecordWriter from INFO to WARN
Modified:
gora/branches/GORA_94/CHANGES.txt
gora/branches/GORA_94/gora-core/src/main/java/org/apache/gora/mapreduce/GoraRecordWriter.java
Modified: gora/branches/GORA_94/CHANGES.txt
URL: http://svn.apache.org/viewvc/gora/branches/GORA_94/CHANGES.txt?rev=1556417&r1=1556416&r2=1556417&view=diff
==============================================================================
--- gora/branches/GORA_94/CHANGES.txt (original)
+++ gora/branches/GORA_94/CHANGES.txt Wed Jan 8 01:01:51 2014
@@ -6,6 +6,8 @@ Gora Change Log
* GORA-94 Upgrade to Apache Avro 1.7.x ==1st Attempt== (Ed Kohlwey via lewismc)
+* GORA-285 Change logging at o.a.g.mapreduce.GoraRecordWriter from INFO to WARN (lewismc)
+
* GORA-117 gora hbase does not have a mechanism to set the caching on a scanner, which makes for poor performance on map/reduce jobs (alfonsonishikawa)
* GORA-281 More flexible file locations for cassandra's config and log4j (Nate McCall via hsaputra)
Modified: gora/branches/GORA_94/gora-core/src/main/java/org/apache/gora/mapreduce/GoraRecordWriter.java
URL: http://svn.apache.org/viewvc/gora/branches/GORA_94/gora-core/src/main/java/org/apache/gora/mapreduce/GoraRecordWriter.java?rev=1556417&r1=1556416&r2=1556417&view=diff
==============================================================================
--- gora/branches/GORA_94/gora-core/src/main/java/org/apache/gora/mapreduce/GoraRecordWriter.java (original)
+++ gora/branches/GORA_94/gora-core/src/main/java/org/apache/gora/mapreduce/GoraRecordWriter.java Wed Jan 8 01:01:51 2014
@@ -52,25 +52,24 @@ public class GoraRecordWriter<K, T> exte
@Override
public void close(TaskAttemptContext context) throws IOException,
InterruptedException {
- try{
- store.close();
- }catch(Exception e){
- LOG.info("Exception at GoraRecordWriter.class while closing datastore." + e.getMessage());
- }
+ try{
+ store.close();
+ }catch(Exception e){
+ LOG.warn("Exception at GoraRecordWriter.class while closing datastore." + e.getMessage());
+ }
}
@Override
public void write(K key, T value) throws IOException, InterruptedException {
- try{
- store.put(key, (Persistent) value);
-
- counter.increment();
- if (counter.isModulo()) {
- LOG.info("Flushing the datastore after " + counter.getRecordsNumber() + " records");
- store.flush();
- }
- }catch(Exception e){
- LOG.info("Exception at GoraRecordWriter.class while writing to datastore." + e.getMessage());
- }
+ try{
+ store.put(key, (Persistent) value);
+ counter.increment();
+ if (counter.isModulo()) {
+ LOG.info("Flushing the datastore after " + counter.getRecordsNumber() + " records");
+ store.flush();
+ }
+ }catch(Exception e){
+ LOG.warn("Exception at GoraRecordWriter.class while writing to datastore." + e.getMessage());
+ }
}
}