nebula-spark入库初始化metaClient异常

问答 问题
1

参考nebula-spark-util中的example写的入库

Caused by: java.lang.InstantiationError: com.vesoft.nebula.client.meta.MetaClient
at com.vesoft.nebula.connector.nebula.MetaProvider.(MetaProvider.scala:21)
at com.vesoft.nebula.connector.writer.NebulaWriter.(NebulaWriter.scala:24)
at com.vesoft.nebula.connector.writer.NebulaVertexWriter.(NebulaVertexWriter.scala:19)
at com.vesoft.nebula.connector.writer.NebulaVertexWriterFactory.createDataWriter(NebulaSourceWriter.scala:28)
at org.apache.spark.sql.execution.datasources.v2.DataWritingSparkTask$.run(WriteToDataSourceV2Exec.scala:113)
at org.apache.spark.sql.execution.datasources.v2.WriteToDataSourceV2Exec$$anonfun$doExecute$2.apply(WriteToDataSourceV2Exec.scala:67)
at org.apache.spark.sql.execution.datasources.v2.WriteToDataSourceV2Exec$$anonfun$doExecute$2.apply(WriteToDataSourceV2Exec.scala:66)
at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:90)
at org.apache.spark.scheduler.Task.run(Task.scala:123)
at org.apache.spark.executor.Executor$TaskRunner$$anonfun$10.apply(Executor.scala:408)
at org.apache.spark.util.Utils$.tryWithSafeFinally(Utils.scala:1360)
at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:414)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
… 1 more

3

val config =
NebulaConnectionConfig
.builder()
.withMetaAddress(“xxx.xxx.xxx:9559”)
.withGraphAddress(“xxx.xxx.xxx:9669”)
.build()

val nebulaWriteVertexConfig: WriteNebulaVertexConfig = WriteNebulaVertexConfig
.builder()
.withSpace(“vid100”)
.withTag(“test”)
.withVidField(“vid”)
.withVidAsProp(false)
.withBatch(1000)
.build()

  resultDf.write.nebula(config, nebulaWriteVertexConfig).writeVertices()

入库相关的配置代码

4

依赖冲突问题,已经解决