Repository: giraph Updated Branches: refs/heads/trunk c1d50bca9 -> 4d9ed36cf
GIRAPH-814 Project: http://git-wip-us.apache.org/repos/asf/giraph/repo Commit: http://git-wip-us.apache.org/repos/asf/giraph/commit/4d9ed36c Tree: http://git-wip-us.apache.org/repos/asf/giraph/tree/4d9ed36c Diff: http://git-wip-us.apache.org/repos/asf/giraph/diff/4d9ed36c Branch: refs/heads/trunk Commit: 4d9ed36cff191b223926cda95d60a308aa727d92 Parents: c1d50bc Author: Claudio Martella <[email protected]> Authored: Wed Feb 19 14:08:39 2014 +0100 Committer: Claudio Martella <[email protected]> Committed: Wed Feb 19 14:08:39 2014 +0100 ---------------------------------------------------------------------- giraph-core/src/main/java/org/apache/giraph/yarn/YarnUtils.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/giraph/blob/4d9ed36c/giraph-core/src/main/java/org/apache/giraph/yarn/YarnUtils.java ---------------------------------------------------------------------- diff --git a/giraph-core/src/main/java/org/apache/giraph/yarn/YarnUtils.java b/giraph-core/src/main/java/org/apache/giraph/yarn/YarnUtils.java index 2e0602a..2eb268f 100644 --- a/giraph-core/src/main/java/org/apache/giraph/yarn/YarnUtils.java +++ b/giraph-core/src/main/java/org/apache/giraph/yarn/YarnUtils.java @@ -33,6 +33,7 @@ import org.apache.hadoop.yarn.api.records.LocalResourceVisibility; import org.apache.hadoop.yarn.conf.YarnConfiguration; import org.apache.hadoop.yarn.util.ConverterUtils; import org.apache.hadoop.yarn.util.Records; +import org.apache.hadoop.util.StringUtils; import java.io.File; import java.io.IOException; import java.util.Map; @@ -187,7 +188,8 @@ public class YarnUtils { } for (String cpEntry : giraphConf.getStrings( MRJobConfig.MAPREDUCE_APPLICATION_CLASSPATH, - MRJobConfig.DEFAULT_MAPREDUCE_APPLICATION_CLASSPATH)) { + StringUtils.getStrings( + MRJobConfig.DEFAULT_MAPREDUCE_APPLICATION_CLASSPATH))) { classPathEnv.append(':').append(cpEntry.trim()); } // add the runtime classpath needed for tests to work
