[
https://issues.apache.org/jira/browse/TINKERPOP-1306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Xia closed TINKERPOP-1306.
-------------------------------
Resolution: Won't Do
Closing given
[discussion|https://lists.apache.org/thread/om2m0phg25s83529p9w0gldmcxz7578h] -
it can be reopened if there is expectation that there will be active work on
this item.
> TraversalVertexPrograms don't store halted traversers
> -----------------------------------------------------
>
> Key: TINKERPOP-1306
> URL: https://issues.apache.org/jira/browse/TINKERPOP-1306
> Project: TinkerPop
> Issue Type: Bug
> Components: process
> Affects Versions: 3.2.0-incubating
> Reporter: Daniel Kuppitz
> Priority: Major
>
> Traversal vertex programs only store their halted traversers if the traversal
> contains another vertex program (job chaining).
> *Simple traversal (wrong result):*
> {noformat}
> gremlin> graph = GraphFactory.open("conf/hadoop/hadoop-gryo.properties")
> ==>hadoopgraph[gryoinputformat->gryooutputformat]
> gremlin> g =
> graph.traversal().withComputer(compute().persist(GraphComputer.Persist.EDGES).result(GraphComputer.ResultGraph.NEW))
> ==>graphtraversalsource[hadoopgraph[gryoinputformat->gryooutputformat],
> graphcomputer]
> gremlin> g.withSack(1f).V().hasLabel("person").as("p").
> gremlin> outE("created").sack(mult).by("weight").inV().
> gremlin> inE("created").sack(mult).by("weight").outV().as("c").
> gremlin> select("p","c").by(id).where("p", lt("c")).
> gremlin> sack().as("weight").
> gremlin> select("p").values("name").as("name").
> gremlin> select("c").values("name").as("coworker")
> ==>josh
> ==>peter
> ==>peter
> gremlin> hdfs.head("output/~g", GryoInputFormat).each {println
> it.property(TraversalVertexProgram.HALTED_TRAVERSERS)}
> vp[empty]
> vp[empty]
> vp[empty]
> vp[empty]
> vp[empty]
> vp[empty]
> gremlin>
> {noformat}
> *With job chaining (correct result):*
> {noformat}
> gremlin> graph = GraphFactory.open("conf/hadoop/hadoop-gryo.properties")
> ==>hadoopgraph[gryoinputformat->gryooutputformat]
> gremlin> g = graph.traversal().withComputer()
> ==>graphtraversalsource[hadoopgraph[gryoinputformat->gryooutputformat],
> graphcomputer]
> gremlin> g.withSack(1f).V().hasLabel("person").as("p").
> gremlin> outE("created").sack(mult).by("weight").inV().
> gremlin> inE("created").sack(mult).by("weight").outV().as("c").
> gremlin> select("p","c").by(id).where("p", lt("c")).
> gremlin> sack().as("weight").
> gremlin> select("p").values("name").as("name").
> gremlin> select("c").values("name").as("coworker").
> gremlin> program(BulkDumperVertexProgram.build().create(graph))
> ==>josh
> ==>peter
> ==>peter
> gremlin> hdfs.head("output/~g", GryoInputFormat).each {println
> it.property(TraversalVertexProgram.HALTED_TRAVERSERS)}
> vp[gremlin.traversalVertexProgram.haltedTraversers->[josh]]
> vp[empty]
> vp[gremlin.traversalVertexProgram.haltedTraversers->[peter, peter]]
> vp[empty]
> vp[empty]
> vp[empty]
> gremlin>
> {noformat}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
