Я пытаюсь написать в orientDB по искры.Вот простой код:
df_select.select("zxPhone", "zxname")
.toDF("id", "zxname")
.write.format("org.apache.spark.orientdb.graphs")
.option("dburl", "myurl")
.option("user", "admin")
.option("password", "admin")
.option("vertextype", "Vgraphx")
.mode("append")
.save()
df_select.select("zxPhone", "num", "name")
.toDF("src", "dst", "markname")
.write.format("org.apache.spark.orientdb.graphs")
.option("dburl", "myurl")
.option("user", "admin")
.option("password", "admin")
.option("vertextype", "Vgraphx")
.option("edgetype", "Egraphx")
.mode("append")
.save()
некоторые данные были записаны успешно, но не все.Я получил исключение, как показано ниже.
Задание прервано из-за сбоя этапа: задание 0 на этапе 218.0 не выполнено 4 раза, последний сбой: потерянное задание 0.3 на этапе 218.0 (TID 2641, yq01-dba-openstorage-bdrp-2017-wallet260.yq01.baidu.com, исполнитель 1): com.orientechnologies.orient.server.distributed.task.ODistributedOperationException: кворум не достигнут, ответы: [success] DB name = "addressList"