gora-commits mailing list archives

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



Mime
View raw message