svn commit: r1556416 - in /gora/trunk: CHANGES.txt gora-core/src/main/java/org/apache/gora/mapreduce/GoraRecordWriter.java

[lewismc]

Author: lewismc
Date: Wed Jan  8 01:00:06 2014
New Revision: 1556416

URL: http://svn.apache.org/r1556416
Log:
GORA-285 Change logging at o.a.g.mapreduce.GoraRecordWriter from INFO to WARN

Modified:
    gora/trunk/CHANGES.txt
    
gora/trunk/gora-core/src/main/java/org/apache/gora/mapreduce/GoraRecordWriter.java

Modified: gora/trunk/CHANGES.txt
URL: 
http://svn.apache.org/viewvc/gora/trunk/CHANGES.txt?rev=1556416&r1=1556415&r2=1556416&view=diff
==============================================================================
--- gora/trunk/CHANGES.txt (original)
+++ gora/trunk/CHANGES.txt Wed Jan  8 01:00:06 2014
@@ -4,6 +4,8 @@
 
 Gora Change Log
 
+* 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/trunk/gora-core/src/main/java/org/apache/gora/mapreduce/GoraRecordWriter.java
URL: 
http://svn.apache.org/viewvc/gora/trunk/gora-core/src/main/java/org/apache/gora/mapreduce/GoraRecordWriter.java?rev=1556416&r1=1556415&r2=1556416&view=diff
==============================================================================
--- 
gora/trunk/gora-core/src/main/java/org/apache/gora/mapreduce/GoraRecordWriter.java
 (original)
+++ 
gora/trunk/gora-core/src/main/java/org/apache/gora/mapreduce/GoraRecordWriter.java
 Wed Jan  8 01:00:06 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());
+    }
   }
 }