You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tinkerpop.apache.org by ok...@apache.org on 2015/12/09 00:24:00 UTC
incubator-tinkerpop git commit: minor nothing.
Repository: incubator-tinkerpop
Updated Branches:
refs/heads/TINKERPOP-1023 34a98111c -> 751478280
minor nothing.
Project: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/commit/75147828
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/tree/75147828
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/diff/75147828
Branch: refs/heads/TINKERPOP-1023
Commit: 7514782802bea54e7e108dd168b87c6cd05dd1d6
Parents: 34a9811
Author: Marko A. Rodriguez <ok...@gmail.com>
Authored: Tue Dec 8 16:23:57 2015 -0700
Committer: Marko A. Rodriguez <ok...@gmail.com>
Committed: Tue Dec 8 16:23:57 2015 -0700
----------------------------------------------------------------------
.../gremlin/spark/process/computer/SparkGraphComputer.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/75147828/spark-gremlin/src/main/java/org/apache/tinkerpop/gremlin/spark/process/computer/SparkGraphComputer.java
----------------------------------------------------------------------
diff --git a/spark-gremlin/src/main/java/org/apache/tinkerpop/gremlin/spark/process/computer/SparkGraphComputer.java b/spark-gremlin/src/main/java/org/apache/tinkerpop/gremlin/spark/process/computer/SparkGraphComputer.java
index bb1eb37..c9b57b8 100644
--- a/spark-gremlin/src/main/java/org/apache/tinkerpop/gremlin/spark/process/computer/SparkGraphComputer.java
+++ b/spark-gremlin/src/main/java/org/apache/tinkerpop/gremlin/spark/process/computer/SparkGraphComputer.java
@@ -141,9 +141,8 @@ public final class SparkGraphComputer extends AbstractHadoopGraphComputer {
// create the spark configuration from the graph computer configuration
hadoopConfiguration.forEach(entry -> sparkConfiguration.set(entry.getKey(), entry.getValue()));
// execute the vertex program and map reducers and if there is a failure, auto-close the spark context
- JavaSparkContext sparkContext = null;
try {
- sparkContext = new JavaSparkContext(SparkContext.getOrCreate(sparkConfiguration));
+ final JavaSparkContext sparkContext = new JavaSparkContext(SparkContext.getOrCreate(sparkConfiguration));
Spark.create(sparkContext.sc()); // this is the context RDD holder that prevents GC
updateLocalConfiguration(sparkContext, sparkConfiguration);
// add the project jars to the cluster