240 发简信
IP属地:江苏
  • 这应该是spark没执行。我遇到另外一个问题,执行任务时,遇到19/08/28 10:29:10 TRACE TransportClient: Sending RPC to 99-48-58-209.lightspeed.elgnil.sbcglobal.net/99.48.58.209:42526
    19/08/28 10:29:10 TRACE TransportClient: Sending request 8112076340557502319 to 99-48-58-209.lightspeed.elgnil.sbcglobal.net/99.48.58.209:42526 took 1 ms
    19/08/28 10:29:10 TRACE MessageDecoder: Received message RpcResponse: RpcResponse{requestId=8112076340557502319, body=NettyManagedBuffer{buf=PooledUnsafeDirectByteBuf(ridx: 21, widx: 68, cap: 32768)}}
    19/08/28 10:29:10 ERROR Inbox: Ignoring error
    java.io.UTFDataFormatException: malformed input around byte 24
    at java.io.DataInputStream.readUTF(DataInputStream.java:634)
    at java.io.DataInputStream.readUTF(DataInputStream.java:564)
    at org.apache.spark.scheduler.TaskDescription$$anonfun$decode$1.apply(TaskDescription.scala:131)
    at org.apache.spark.scheduler.TaskDescription$$anonfun$decode$1.apply(TaskDescription.scala:130)
    at scala.collection.immutable.Range.foreach(Range.scala:160)
    at org.apache.spark.scheduler.TaskDescription$.decode(TaskDescription.scala:130)
    at org.apache.spark.executor.CoarseGrainedExecutorBackend$$anonfun$receive$1.applyOrElse(CoarseGrainedExecutorBackend.scala:96)
    at org.apache.spark.rpc.netty.Inbox$$anonfun$process$1.apply$mcV$sp(Inbox.scala:117)
    at org.apache.spark.rpc.netty.Inbox.safelyCall(Inbox.scala:205)
    at org.apache.spark.rpc.netty.Inbox.process(Inbox.scala:101)
    at org.apache.spark.rpc.netty.Dispatcher$MessageLoop.run(Dispatcher.scala:221)
    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) 之后就一直运行中,不报错,也不结束。不知道有没有遇到过

    JanusGraph---TinkerPop’s Hadoop-Gremlin

    TinkerPop’s Hadoop-Gremlin JanusGraph with TinkerPop’s Hadoop-Gremlin 利用Hadoop-Gremlin批...

  • 请问解决了吗?

    JanusGraph---TinkerPop’s Hadoop-Gremlin

    TinkerPop’s Hadoop-Gremlin JanusGraph with TinkerPop’s Hadoop-Gremlin 利用Hadoop-Gremlin批...

  • 我也遇到

    JanusGraph---TinkerPop’s Hadoop-Gremlin

    TinkerPop’s Hadoop-Gremlin JanusGraph with TinkerPop’s Hadoop-Gremlin 利用Hadoop-Gremlin批...

  • 想问一下博主,remote调用方式,在创建顶点和线的时候,如何使用事务?使用样例的时候,调用g.addV() 等后,再调用g.tx().commit()都抛异常提示不支持事务。是否是在remote调用方式的时候,不支持事务提交。
    另外我启动了一个远程控制台,和一个本地控制台,在远程控制台更改了一个顶点的属性,然后commit,发现在本地控制台去查询该顶点的属性后,并没有看到更改后的新值。我必须在本地控制台,commit调用之后,才能看到新的值,这个不太清楚这个机制是什么,博主遇到过吗?

    janusGraph踩坑记录

    PS:希望可以帮助大家踩坑,如果大家知道文中待回答的问题答案,欢迎留言,我会尽快试验并更新,为大家服务。 一 问题:使用jar包连接 JanusGraph 会挂掉,报连不上远...