用spark 导入数据后,查询数据出现 Storage Error: The leader has changed. Try again later

提问参考模版:

  • nebula 版本:neubla2.0.1
  • 部署方式(分布式):
  • 是否为线上版本:Y
  • 硬件信息
    • 磁盘 ssd
    • CPU 32C、内存64G
  • 问题的具体描述
    用spark 导入数据后,查询数据出现 Storage Error: The leader has changed. Try again later

这边show hosts 也是不平衡的,这边手动平衡balance leader ,后 要查询每个图多次后才可以使用不出现Storage Error: The leader has changed. Try again later
这个是什么原因导致的,是否每次导入后都要balance leader ,还是nebula 可以配置自己平衡,

leader change 一般重试请求就好了

https://docs.nebula-graph.com.cn/2.0.1/2.quick-start/0.FAQ/#the_leader_has_changed_try_again_later

2 个赞

你用spark导入不报这个错误吗??? 我使用Flink导入的话就报这个错误了, 其实查询还好

你的数据量多大, 有可能是导入速度过快或数据集中在某个part上导致storag压力过大发生leader change。
可以适当调小导入时的并发度和batch