crunch-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gr...@apache.org
Subject git commit: CRUNCH-349 Avoid NPE when logging NPE
Date Tue, 18 Feb 2014 22:28:26 GMT
Repository: crunch
Updated Branches:
  refs/heads/apache-crunch-0.8 1aefb1a97 -> 2964ca744


CRUNCH-349 Avoid NPE when logging NPE


Project: http://git-wip-us.apache.org/repos/asf/crunch/repo
Commit: http://git-wip-us.apache.org/repos/asf/crunch/commit/2964ca74
Tree: http://git-wip-us.apache.org/repos/asf/crunch/tree/2964ca74
Diff: http://git-wip-us.apache.org/repos/asf/crunch/diff/2964ca74

Branch: refs/heads/apache-crunch-0.8
Commit: 2964ca744ae7d65de8dec2b4244a9db11f73094d
Parents: 1aefb1a
Author: Gabriel Reid <greid@apache.org>
Authored: Tue Feb 18 22:23:01 2014 +0100
Committer: Gabriel Reid <greid@apache.org>
Committed: Tue Feb 18 23:27:53 2014 +0100

----------------------------------------------------------------------
 .../src/main/java/org/apache/crunch/impl/mr/run/RTNode.java       | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/crunch/blob/2964ca74/crunch-core/src/main/java/org/apache/crunch/impl/mr/run/RTNode.java
----------------------------------------------------------------------
diff --git a/crunch-core/src/main/java/org/apache/crunch/impl/mr/run/RTNode.java b/crunch-core/src/main/java/org/apache/crunch/impl/mr/run/RTNode.java
index f17beb0..5a7949e 100644
--- a/crunch-core/src/main/java/org/apache/crunch/impl/mr/run/RTNode.java
+++ b/crunch-core/src/main/java/org/apache/crunch/impl/mr/run/RTNode.java
@@ -31,7 +31,6 @@ import org.apache.crunch.impl.mr.emit.OutputEmitter;
 import org.apache.crunch.types.Converter;
 import org.apache.crunch.types.PType;
 import org.apache.hadoop.conf.Configuration;
-import org.apache.hadoop.mapreduce.TaskInputOutputContext;
 
 public class RTNode implements Serializable {
 
@@ -99,7 +98,7 @@ public class RTNode implements Serializable {
       fn.process(input, emitter);
     } catch (CrunchRuntimeException e) {
       if (!e.wasLogged()) {
-        LOG.info(String.format("Crunch exception in '%s' for input: %s", nodeName, input.toString()),
e);
+        LOG.info(String.format("Crunch exception in '%s' for input: %s", nodeName, input),
e);
         e.markLogged();
       }
       throw e;


Mime
View raw message