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 <[email protected]> Authored: Tue Feb 18 22:23:01 2014 +0100 Committer: Gabriel Reid <[email protected]> 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;
