Repository: giraph Updated Branches: refs/heads/trunk acd716fd2 -> a45450cc5
GIRAPH-964: Remove quotes from output partition specification in hive-io Project: http://git-wip-us.apache.org/repos/asf/giraph/repo Commit: http://git-wip-us.apache.org/repos/asf/giraph/commit/a45450cc Tree: http://git-wip-us.apache.org/repos/asf/giraph/tree/a45450cc Diff: http://git-wip-us.apache.org/repos/asf/giraph/diff/a45450cc Branch: refs/heads/trunk Commit: a45450cc5bdac12432651611effb975fa4c5481c Parents: acd716f Author: Maja Kabiljo <[email protected]> Authored: Fri Nov 7 10:47:20 2014 -0800 Committer: Maja Kabiljo <[email protected]> Committed: Fri Nov 7 10:47:20 2014 -0800 ---------------------------------------------------------------------- CHANGELOG | 2 ++ .../src/main/java/org/apache/giraph/hive/HiveGiraphRunner.java | 6 +++++- 2 files changed, 7 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/giraph/blob/a45450cc/CHANGELOG ---------------------------------------------------------------------- diff --git a/CHANGELOG b/CHANGELOG index af7c733..e6b2470 100644 --- a/CHANGELOG +++ b/CHANGELOG @@ -1,6 +1,8 @@ Giraph Change Log Release 1.1.0 - unreleased + GIRAPH-964: Remove quotes from output partition specification in hive-io (majakabiljo) + GIRAPH-963: Aggregators may not be initialized properly (edunov via majakabiljo) GIRAPH-955: Allow vertex/edge/message value to be configurable (ikabiljo via majakabiljo) http://git-wip-us.apache.org/repos/asf/giraph/blob/a45450cc/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 fbc24f8..8849f55 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 @@ -238,7 +238,11 @@ public class HiveGiraphRunner implements Tool { HIVE_VERTEX_OUTPUT_PROFILE_ID.set(conf, "vertex_output_profile"); HIVE_VERTEX_OUTPUT_TABLE.set(conf, tableName); if (partitionFilter != null) { - HIVE_VERTEX_OUTPUT_PARTITION.set(conf, partitionFilter); + HIVE_VERTEX_OUTPUT_PARTITION.set(conf, + // People often put quotes around partition values by mistake, + // and it's invalid to have it, so remove all quotes from + // partitionFilter + partitionFilter.replaceAll("'", "")); } }
