gora-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From lewi...@apache.org
Subject svn commit: r1556416 - in /gora/trunk: CHANGES.txt gora-core/src/main/java/org/apache/gora/mapreduce/GoraRecordWriter.java
Date Wed, 08 Jan 2014 01:00:06 GMT
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());
+    }
   }
 }



Mime
View raw message