You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tinkerpop.apache.org by dk...@apache.org on 2015/09/03 19:52:17 UTC
[50/50] [abbrv] incubator-tinkerpop git commit: allow any graph that
supports persistence in BLVP
allow any graph that supports persistence in BLVP
Project: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/commit/45d649d8
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/tree/45d649d8
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/diff/45d649d8
Branch: refs/heads/blvp
Commit: 45d649d8c8269e088db677e15ac1413f0b1dbf2c
Parents: 93bc0a8
Author: Daniel Kuppitz <da...@hotmail.com>
Authored: Thu Sep 3 19:50:58 2015 +0200
Committer: Daniel Kuppitz <da...@hotmail.com>
Committed: Thu Sep 3 19:50:58 2015 +0200
----------------------------------------------------------------------
.../computer/bulkloading/BulkLoaderVertexProgram.java | 9 +++++++--
1 file changed, 7 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/45d649d8/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/computer/bulkloading/BulkLoaderVertexProgram.java
----------------------------------------------------------------------
diff --git a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/computer/bulkloading/BulkLoaderVertexProgram.java b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/computer/bulkloading/BulkLoaderVertexProgram.java
index d5eb835..8f43a78 100644
--- a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/computer/bulkloading/BulkLoaderVertexProgram.java
+++ b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/computer/bulkloading/BulkLoaderVertexProgram.java
@@ -172,8 +172,13 @@ public class BulkLoaderVertexProgram implements VertexProgram<Tuple> {
graph = GraphFactory.open(configuration.subset(WRITE_GRAPH_CFG_KEY));
LOGGER.info("Opened Graph instance: {}", graph);
try {
- if (!graph.features().graph().supportsConcurrentAccess()) {
- throw new IllegalStateException("The given graph instance does not allow concurrent access.");
+ //if (!graph.features().graph().supportsConcurrentAccess()) {
+ // throw new IllegalStateException("The given graph instance does not allow concurrent access.");
+ //}
+ // TODO: the following check is a hack to allow Neo4j in standalone mode; this is very fragile and
+ // should be replaced by the previous check once we have Neo4j HA available
+ if (!graph.features().graph().supportsPersistence()) {
+ throw new IllegalStateException("The given graph instance does not support persistence.");
}
g = graph.traversal();
} catch (Exception e) {