GIRAPH-580: NPE in HiveGiraphRunner when the vertex output format is not defined (aching)
Project: http://git-wip-us.apache.org/repos/asf/giraph/repo Commit: http://git-wip-us.apache.org/repos/asf/giraph/commit/a4d33303 Tree: http://git-wip-us.apache.org/repos/asf/giraph/tree/a4d33303 Diff: http://git-wip-us.apache.org/repos/asf/giraph/diff/a4d33303 Branch: refs/heads/perf Commit: a4d33303969c060e02b9bc76b90c3ba06e9ba9e3 Parents: 1566827 Author: Avery Ching <[email protected]> Authored: Fri Mar 22 09:45:40 2013 -0700 Committer: Avery Ching <[email protected]> Committed: Fri Mar 22 09:56:33 2013 -0700 ---------------------------------------------------------------------- CHANGELOG | 3 +++ .../org/apache/giraph/hive/HiveGiraphRunner.java | 6 ++++-- 2 files changed, 7 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/giraph/blob/a4d33303/CHANGELOG ---------------------------------------------------------------------- diff --git a/CHANGELOG b/CHANGELOG index db8f4ce..50ed932 100644 --- a/CHANGELOG +++ b/CHANGELOG @@ -1,6 +1,9 @@ Giraph Change Log Release 0.2.0 - unreleased + GIRAPH-580: NPE in HiveGiraphRunner when the vertex output format is + not defined (aching) + GIRAPH-510: Remove HBase Cruft (kelarini via nitay) GIRAPH-566: Make option for aggregators to be configurable (majakabiljo) http://git-wip-us.apache.org/repos/asf/giraph/blob/a4d33303/giraph-hive/src/main/java/org/apache/giraph/hive/HiveGiraphRunner.java ---------------------------------------------------------------------- diff --git a/giraph-hive/src/main/java/org/apache/giraph/hive/HiveGiraphRunner.java b/giraph-hive/src/main/java/org/apache/giraph/hive/HiveGiraphRunner.java index 8788a9d..efc08d3 100644 --- a/giraph-hive/src/main/java/org/apache/giraph/hive/HiveGiraphRunner.java +++ b/giraph-hive/src/main/java/org/apache/giraph/hive/HiveGiraphRunner.java @@ -680,8 +680,10 @@ public class HiveGiraphRunner implements Tool { LOG.info(LOG_PREFIX + "-outputPartition=\"" + hiveOutputDescription.getPartitionValues() + "\""); } - LOG.info(LOG_PREFIX + "-outputFormatClass=" + - classes.getVertexOutputFormatClass().getCanonicalName()); + if (classes.getVertexOutputFormatClass() != null) { + LOG.info(LOG_PREFIX + "-outputFormatClass=" + + classes.getVertexOutputFormatClass().getCanonicalName()); + } LOG.info(LOG_PREFIX + "-workers=" + workers); }
