nebula2.5.0 submit job stats导致节点挂掉

我本来用的client写 然后一直报错 效率太慢
com.vesoft.nebula.client.graph.exception.IOErrorException: java.net.SocketTimeoutException: Read timed out+details
com.vesoft.nebula.client.graph.exception.IOErrorException: java.net.SocketTimeoutException: Read timed out
at com.vesoft.nebula.client.graph.net.SyncConnection.execute(SyncConnection.java:106)
at com.vesoft.nebula.client.graph.net.Session.execute(Session.java:80)
at com.vesoft.nebula.exchange.GraphProvider.submit(GraphProvider.scala:58)
at com.vesoft.nebula.exchange.writer.NebulaGraphClientWriter.writeVertices(ServerBaseWriter.scala:151)
at com.vesoft.nebula.exchange.processor.VerticesProcessor$$anonfun$com$vesoft$nebula$exchange$processor$VerticesProcessor$$processEachPartition$1.apply(VerticesProcessor.scala:82)
at com.vesoft.nebula.exchange.processor.VerticesProcessor$$anonfun$com$vesoft$nebula$exchange$processor$VerticesProcessor$$processEachPartition$1.apply(VerticesProcessor.scala:80)
at scala.collection.Iterator$class.foreach(Iterator.scala:891)
at scala.collection.AbstractIterator.foreach(Iterator.scala:1334)
at com.vesoft.nebula.exchange.processor.VerticesProcessor.com$vesoft$nebula$exchange$processor$VerticesProcessor$$processEachPartition(VerticesProcessor.scala:80)
at com.vesoft.nebula.exchange.processor.VerticesProcessor$$anonfun$process$4.apply(VerticesProcessor.scala:274)
at com.vesoft.nebula.exchange.processor.VerticesProcessor$$anonfun$process$4.apply(VerticesProcessor.scala:274)
at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$29.apply(RDD.scala:935)
at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$29.apply(RDD.scala:935)
at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:2079)
at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:2079)
at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:87)
at org.apache.spark.scheduler.Task.run(Task.scala:109)
at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:345)
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)

然后想着用这种效率高的 没想到整出事了 滋滋

请教一下 这个日志是啥意思 是不是 响应不过来
W0909 15:18:28.032685 127696 RaftPart.cpp:993] [Port: 9780, Space: 1, Part: 12] Only 0 hosts succeeded, Need to try again
W0909 15:18:28.120237 127682 RaftPart.cpp:993] [Port: 9780, Space: 1, Part: 4] Only 0 hosts succeeded, Need to try again
W0909 15:18:28.208104 127696 RaftPart.cpp:993] [Port: 9780, Space: 1, Part: 40] Only 0 hosts succeeded, Need to try again
W0909 15:18:28.295831 127689 RaftPart.cpp:993] [Port: 9780, Space: 1, Part: 38] Only 0 hosts succeeded, Need to try again
W0909 15:18:28.384794 127689 RaftPart.cpp:993] [Port: 9780, Space: 1, Part: 3] Only 0 hosts succeeded, Need to try again
W0909 15:18:28.471932 127689 RaftPart.cpp:993] [Port: 9780, Space: 1, Part: 44] Only 0 hosts succeeded, Need to try again
W0909 15:18:28.562896 127687 RaftPart.cpp:993] [Port: 9780, Space: 1, Part: 38] Only 0 hosts succeeded, Need to try again
W0909 15:18:28.648460 127687 RaftPart.cpp:993] [Port: 9780, Space: 1, Part: 40] Only 0 hosts succeeded, Need to try again
W0909 15:18:28.741964 127698 RaftPart.cpp:993] [Port: 9780, Space: 1, Part: 30] Only 0 hosts succeeded, Need to try again
W0909 15:18:28.830642 127687 RaftPart.cpp:993] [Port: 9780, Space: 1, Part: 8] Only 0 hosts succeeded, Need to try again

很多吗 你是不是有防火墙 你先在console手动插入一条 看能不能读出来

主要是我数据都写进去了

还有可能是raft那里超时了 有个参数可以改 ==
raft_rpc_timeout_ms(默认500),改到个1s或者更大

已经写进去了几千万了 但是这日志一直在刷

收到

像这种在重启的时候 报这个信息 应该怎么处理 我看文档 kill -9 会丢数据

[INFO] Stopping nebula-storaged…
[INFO] Done
[ERROR] nebula-storaged already running: 131191
[root@h30067 scripts]# sh nebula-storaged.service restart
[INFO] Stopping nebula-storaged…
[INFO] Done
[ERROR] nebula-storaged already running: 131191

这个是有可能会丢

浙ICP备20010487号