[ https://issues.apache.org/jira/browse/TINKERPOP-1876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16340550#comment-16340550 ]
ping commented on TINKERPOP-1876: --------------------------------- hello stephen i ccannot use goole to connect with other users , because i cannot resign a google account ,they cannot connect my mobile number, is there any way to communicate with other users? ---Original--- From: "stephen mallette (JIRA)"<j...@apache.org> Date: 2018/1/23 02:09:09 To: "970356792"<970356...@qq.com>; Subject: [jira] [Closed] (TINKERPOP-1876) I cannot use the bulkload withspark [ https://issues.apache.org/jira/browse/TINKERPOP-1876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] stephen mallette closed TINKERPOP-1876. --------------------------------------- Resolution: Invalid We don't use JIRA for tracking usage questions - could you please post your question to the gremlin-users mailing list? https://groups.google.com/forum/#!forum/gremlin-users Or, it might even be better suite for the JanusGraph mailing list: https://groups.google.com/forum/#!forum/janusgraph-users -- This message was sent by Atlassian JIRA (v7.6.3#76005) > I cannot use the bulkload with spark > ------------------------------------ > > Key: TINKERPOP-1876 > URL: https://issues.apache.org/jira/browse/TINKERPOP-1876 > Project: TinkerPop > Issue Type: Test > Components: plugin > Affects Versions: 3.2.6 > Reporter: ping > Priority: Major > Labels: bulkload > > here is the data > {"timestamp":"1510335280","name":"sendv54sxu8f12g.ihance.net","type":"a","value":"52.52.81.55"}## > {"timestamp":"1510338448","name":"*.2925.com.dycdn.com","type":"a","value":"121.201.116.57"}## > {"timestamp":"1510308398","name":"*.2bask.com","type":"a","value":"176.31.246.156"}## > {"timestamp":"1510350705","name":"*.5thlegdata.com","type":"a","value":"199.34.228.100"}## > {"timestamp":"1510350937","name":"*.819.cn","type":"a","value":"118.190.84.164"}## > {"timestamp":"1510301149","name":"*.acart.iii.com","type":"a","value":"66.171.203.156"}## > {"timestamp":"1510337980","name":"*.aineistot.lamk.fi","type":"a","value":"193.166.79.79"}## > {"timestamp":"1510344687","name":"*.amagervvs.dk","type":"a","value":"185.17.52.58"}## > {"timestamp":"1510350321","name":"*.app-devel.services.actx.com","type":"a","value":"34.209.35.25"}## > {"timestamp":"1510335280","name":"sendv54sxu8f12g.ihance.net","type":"a","value":"52.52.81.55"} > {"timestamp":"1510338448","name":"*.2925.com.dycdn.com","type":"a","value":"121.201.116.57"} > {"timestamp":"1510308398","name":"*.2bask.com","type":"a","value":"176.31.246.156"} > {"timestamp":"1510350705","name":"*.5thlegdata.com","type":"a","value":"199.34.228.100"} > {"timestamp":"1510350937","name":"*.819.cn","type":"a","value":"118.190.84.164"} > {"timestamp":"1510301149","name":"*.acart.iii.com","type":"a","value":"66.171.203.156"} > {"timestamp":"1510337980","name":"*.aineistot.lamk.fi","type":"a","value":"193.166.79.79"} > {"timestamp":"1510344687","name":"*.amagervvs.dk","type":"a","value":"185.17.52.58"} > {"timestamp":"1510350321","name":"*.app-devel.services.actx.com","type":"a","value":"34.209.35.25"} > the bulk could load vertices successfully ,but when i make edges something > wrong happened the groovy script is > def parse(line, factory) { > if (line.toString().contains("##")){ > println "model1" > String > noquotes=line.replace("\"","").replace("\{","").replace("}","") > def (timestamp,host,type,ip)=noquotes.split(",") > String hostname=host.split(":")[1] > String ipdetail=ip.split(":")[1] > String time=timestamp.split(":")[1] > //def label = parts[1] != "" ? "person" : "address" > def v1 = factory.vertex(hostname, "host") > def v2 = factory.vertex(ipdetail) > def edge=factory.edge(v1, v2, "pointto") > edge.properties("timestamp",time) > return v1 > }else{ > println "model2" > String > noquotes=line.replace("\"","").replace("\{","").replace("}","") > def (timestamp,host,type,ip)=noquotes.split(",") > String hostname=host.split(":")[1] > String ipdetail=ip.split(":")[1] > String time=timestamp.split(":")[1] > //def label = parts[1] != "" ? "person" : "address" > def v1 = factory.vertex(ipdetail, "ip") > def v2 = factory.vertex(hostname) > def edge=factory.edge(v2, v1, "pointto") > edge.properties("timestamp",time) > return v1 > } > } > > error stack is > Opened Graph instance: standardjanusgraph[hbase:[10.9.128.12]] > java.util.NoSuchElementException > at > org.apache.tinkerpop.gremlin.process.traversal.util.DefaultTraversal.next(DefaultTraversal.java:204) > at > org.apache.tinkerpop.gremlin.process.computer.bulkloading.BulkLoader.getVertexById(BulkLoader.java:118) > at > org.apache.tinkerpop.gremlin.process.computer.bulkloading.BulkLoaderVertexProgram.lambda$executeInternal$4(BulkLoaderVertexProgram.java:251) > at java.util.Iterator.forEachRemaining(Iterator.java:116) > at > org.apache.tinkerpop.gremlin.process.computer.bulkloading.BulkLoaderVertexProgram.executeInternal(BulkLoaderVertexProgram.java:249) > at > org.apache.tinkerpop.gremlin.process.computer.bulkloading.BulkLoaderVertexProgram.execute(BulkLoaderVertexProgram.java:197) > at > org.apache.tinkerpop.gremlin.spark.process.computer.SparkExecutor.lambda$null$5(SparkExecutor.java:118) > at > org.apache.tinkerpop.gremlin.util.iterator.IteratorUtils$3.next(IteratorUtils.java:247) > at > scala.collection.convert.Wrappers$JIteratorWrapper.next(Wrappers.scala:42) > at scala.collection.Iterator$$anon$14.hasNext(Iterator.scala:389) > at scala.collection.Iterator$$anon$13.hasNext(Iterator.scala:371) > at > org.apache.spark.util.collection.ExternalSorter.insertAll(ExternalSorter.scala:189) > at > org.apache.spark.shuffle.sort.SortShuffleWriter.write(SortShuffleWriter.scala:64) > at > org.apache.spark.scheduler.ShuffleMapTask.runTask(ShuffleMapTask.scala:73) > at > org.apache.spark.scheduler.ShuffleMapTask.runTask(ShuffleMapTask.scala:41) > at org.apache.spark.scheduler.Task.run(Task.scala:89) > at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:214) > at > java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) > at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) > at java.lang.Thread.run(Thread.java:748) > > this is the gremlin script > graph = > GraphFactory.open("/user/janusgraph-0.2.0-hadoop2/conf/hadoop-graph/hadoop-script.properties") > graph.configuration().setProperty("gremlin.hadoop.scriptInputFormat.script", > "host_ip2.groovy") > graph.configuration().setInputLocation("host_ip.json") > blvp = > BulkLoaderVertexProgram.build().writeGraph("/tmp/10.properties").create(graph) > graph.compute(SparkGraphComputer).workers(1).configure("fs.defaultFS", > "hdfs://am4:8020").program(blvp).submit().get() > > is there any one can help me? > -- This message was sent by Atlassian JIRA (v7.6.3#76005)