svn commit: r1556417 - in /gora/branches/GORA_94: CHANGES.txt gora-core/src/main/java/org/apache/gora/mapreduce/GoraRecordWriter.java

[lewismc]

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());
+    }
   }
 }