试试
“ip1:port1”,“ip2:port2”,“ip3:port3”
"“ip1:9559”,“ip2:9559”,“ip3:9559"”
就解析端口号失败
22/02/24 15:44:49 ERROR Executor: Exception in task 0.0 in stage 2.0 (TID 2)
java.lang.IllegalArgumentException: Unparseable port number: "ip1:9559"
at com.google.common.net.HostAndPort.fromString(HostAndPort.java:181)
at com.vesoft.nebula.connector.NebulaOptions$$anonfun$getMetaAddress$1.apply(NebulaOptions.scala:185)
at com.vesoft.nebula.connector.NebulaOptions$$anonfun$getMetaAddress$1.apply(NebulaOptions.scala:183)
at scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:33)
at scala.collection.mutable.ArrayOps$ofRef.foreach(ArrayOps.scala:186)
at com.vesoft.nebula.connector.NebulaOptions.getMetaAddress(NebulaOptions.scala:183)
at com.vesoft.nebula.connector.writer.NebulaWriter.<init>(NebulaWriter.scala:23)
at com.vesoft.nebula.connector.writer.NebulaVertexWriter.<init>(NebulaVertexWriter.scala:18)
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:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
sorry，你的方法是正确的，我扒了 spark-connector 作者之前的回复，“ip1:port1,ip2:port2,ip3:port3” 这个，
你确认所有的 ip 和端口号都是 ping 的通吗
记得换成真实的 ip 地址
能通，我是用docker-compose启动一个测试环境也是同样的错误
有时候还有这个错误
22/02/24 16:16:32 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:32 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:32 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:32 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:32 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:32 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:32 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:32 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:32 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:32 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:32 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:32 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:32 ERROR Executor: Exception in task 6.0 in stage 38.0 (TID 717)
com.facebook.thrift.TApplicationException: Method name getSpace not found
at com.facebook.thrift.TApplicationException.read(TApplicationException.java:133)
at com.vesoft.nebula.meta.MetaService$Client.recv_getSpace(MetaService.java:541)
at com.vesoft.nebula.meta.MetaService$Client.getSpace(MetaService.java:516)
at com.vesoft.nebula.client.meta.MetaClient.getSpace(MetaClient.java:228)
at com.vesoft.nebula.connector.nebula.MetaProvider.getVidType(MetaProvider.scala:66)
at com.vesoft.nebula.connector.writer.NebulaWriter.<init>(NebulaWriter.scala:40)
at com.vesoft.nebula.connector.writer.NebulaVertexWriter.<init>(NebulaVertexWriter.scala:18)
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:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
22/02/24 16:16:32 ERROR Executor: Exception in task 2.0 in stage 38.0 (TID 713)
com.facebook.thrift.TApplicationException: Method name getSpace not found
at com.facebook.thrift.TApplicationException.read(TApplicationException.java:133)
at com.vesoft.nebula.meta.MetaService$Client.recv_getSpace(MetaService.java:541)
at com.vesoft.nebula.meta.MetaService$Client.getSpace(MetaService.java:516)
at com.vesoft.nebula.client.meta.MetaClient.getSpace(MetaClient.java:228)
at com.vesoft.nebula.connector.nebula.MetaProvider.getVidType(MetaProvider.scala:66)
at com.vesoft.nebula.connector.writer.NebulaWriter.<init>(NebulaWriter.scala:40)
at com.vesoft.nebula.connector.writer.NebulaVertexWriter.<init>(NebulaVertexWriter.scala:18)
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:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
22/02/24 16:16:32 ERROR Executor: Exception in task 7.0 in stage 38.0 (TID 718)
com.facebook.thrift.TApplicationException: Method name getSpace not found
at com.facebook.thrift.TApplicationException.read(TApplicationException.java:133)
at com.vesoft.nebula.meta.MetaService$Client.recv_getSpace(MetaService.java:541)
at com.vesoft.nebula.meta.MetaService$Client.getSpace(MetaService.java:516)
at com.vesoft.nebula.client.meta.MetaClient.getSpace(MetaClient.java:228)
at com.vesoft.nebula.connector.nebula.MetaProvider.getVidType(MetaProvider.scala:66)
at com.vesoft.nebula.connector.writer.NebulaWriter.<init>(NebulaWriter.scala:40)
at com.vesoft.nebula.connector.writer.NebulaVertexWriter.<init>(NebulaVertexWriter.scala:18)
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:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
22/02/24 16:16:32 ERROR Executor: Exception in task 1.0 in stage 38.0 (TID 712)
com.facebook.thrift.TApplicationException: Method name getSpace not found
at com.facebook.thrift.TApplicationException.read(TApplicationException.java:133)
at com.vesoft.nebula.meta.MetaService$Client.recv_getSpace(MetaService.java:541)
at com.vesoft.nebula.meta.MetaService$Client.getSpace(MetaService.java:516)
at com.vesoft.nebula.client.meta.MetaClient.getSpace(MetaClient.java:228)
at com.vesoft.nebula.connector.nebula.MetaProvider.getVidType(MetaProvider.scala:66)
at com.vesoft.nebula.connector.writer.NebulaWriter.<init>(NebulaWriter.scala:40)
at com.vesoft.nebula.connector.writer.NebulaVertexWriter.<init>(NebulaVertexWriter.scala:18)
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:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
22/02/24 16:16:32 ERROR Executor: Exception in task 11.0 in stage 38.0 (TID 722)
com.facebook.thrift.TApplicationException: Method name getSpace not found
at com.facebook.thrift.TApplicationException.read(TApplicationException.java:133)
at com.vesoft.nebula.meta.MetaService$Client.recv_getSpace(MetaService.java:541)
at com.vesoft.nebula.meta.MetaService$Client.getSpace(MetaService.java:516)
at com.vesoft.nebula.client.meta.MetaClient.getSpace(MetaClient.java:228)
at com.vesoft.nebula.connector.nebula.MetaProvider.getVidType(MetaProvider.scala:66)
at com.vesoft.nebula.connector.writer.NebulaWriter.<init>(NebulaWriter.scala:40)
at com.vesoft.nebula.connector.writer.NebulaVertexWriter.<init>(NebulaVertexWriter.scala:18)
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:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
22/02/24 16:16:32 ERROR Executor: Exception in task 3.0 in stage 38.0 (TID 714)
com.facebook.thrift.TApplicationException: Method name getSpace not found
at com.facebook.thrift.TApplicationException.read(TApplicationException.java:133)
at com.vesoft.nebula.meta.MetaService$Client.recv_getSpace(MetaService.java:541)
at com.vesoft.nebula.meta.MetaService$Client.getSpace(MetaService.java:516)
at com.vesoft.nebula.client.meta.MetaClient.getSpace(MetaClient.java:228)
at com.vesoft.nebula.connector.nebula.MetaProvider.getVidType(MetaProvider.scala:66)
at com.vesoft.nebula.connector.writer.NebulaWriter.<init>(NebulaWriter.scala:40)
at com.vesoft.nebula.connector.writer.NebulaVertexWriter.<init>(NebulaVertexWriter.scala:18)
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:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
22/02/24 16:16:32 ERROR Executor: Exception in task 4.0 in stage 38.0 (TID 715)
com.facebook.thrift.TApplicationException: Method name getSpace not found
at com.facebook.thrift.TApplicationException.read(TApplicationException.java:133)
at com.vesoft.nebula.meta.MetaService$Client.recv_getSpace(MetaService.java:541)
at com.vesoft.nebula.meta.MetaService$Client.getSpace(MetaService.java:516)
at com.vesoft.nebula.client.meta.MetaClient.getSpace(MetaClient.java:228)
at com.vesoft.nebula.connector.nebula.MetaProvider.getVidType(MetaProvider.scala:66)
at com.vesoft.nebula.connector.writer.NebulaWriter.<init>(NebulaWriter.scala:40)
at com.vesoft.nebula.connector.writer.NebulaVertexWriter.<init>(NebulaVertexWriter.scala:18)
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:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
22/02/24 16:16:32 ERROR Executor: Exception in task 9.0 in stage 38.0 (TID 720)
com.facebook.thrift.TApplicationException: Method name getSpace not found
at com.facebook.thrift.TApplicationException.read(TApplicationException.java:133)
at com.vesoft.nebula.meta.MetaService$Client.recv_getSpace(MetaService.java:541)
at com.vesoft.nebula.meta.MetaService$Client.getSpace(MetaService.java:516)
at com.vesoft.nebula.client.meta.MetaClient.getSpace(MetaClient.java:228)
at com.vesoft.nebula.connector.nebula.MetaProvider.getVidType(MetaProvider.scala:66)
at com.vesoft.nebula.connector.writer.NebulaWriter.<init>(NebulaWriter.scala:40)
at com.vesoft.nebula.connector.writer.NebulaVertexWriter.<init>(NebulaVertexWriter.scala:18)
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:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
22/02/24 16:16:32 ERROR Executor: Exception in task 10.0 in stage 38.0 (TID 721)
com.facebook.thrift.TApplicationException: Method name getSpace not found
at com.facebook.thrift.TApplicationException.read(TApplicationException.java:133)
at com.vesoft.nebula.meta.MetaService$Client.recv_getSpace(MetaService.java:541)
at com.vesoft.nebula.meta.MetaService$Client.getSpace(MetaService.java:516)
at com.vesoft.nebula.client.meta.MetaClient.getSpace(MetaClient.java:228)
at com.vesoft.nebula.connector.nebula.MetaProvider.getVidType(MetaProvider.scala:66)
at com.vesoft.nebula.connector.writer.NebulaWriter.<init>(NebulaWriter.scala:40)
at com.vesoft.nebula.connector.writer.NebulaVertexWriter.<init>(NebulaVertexWriter.scala:18)
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:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
22/02/24 16:16:32 ERROR Executor: Exception in task 5.0 in stage 38.0 (TID 716)
com.facebook.thrift.TApplicationException: Method name getSpace not found
at com.facebook.thrift.TApplicationException.read(TApplicationException.java:133)
at com.vesoft.nebula.meta.MetaService$Client.recv_getSpace(MetaService.java:541)
at com.vesoft.nebula.meta.MetaService$Client.getSpace(MetaService.java:516)
at com.vesoft.nebula.client.meta.MetaClient.getSpace(MetaClient.java:228)
at com.vesoft.nebula.connector.nebula.MetaProvider.getVidType(MetaProvider.scala:66)
at com.vesoft.nebula.connector.writer.NebulaWriter.<init>(NebulaWriter.scala:40)
at com.vesoft.nebula.connector.writer.NebulaVertexWriter.<init>(NebulaVertexWriter.scala:18)
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:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
22/02/24 16:16:32 ERROR Executor: Exception in task 8.0 in stage 38.0 (TID 719)
com.facebook.thrift.TApplicationException: Method name getSpace not found
at com.facebook.thrift.TApplicationException.read(TApplicationException.java:133)
at com.vesoft.nebula.meta.MetaService$Client.recv_getSpace(MetaService.java:541)
at com.vesoft.nebula.meta.MetaService$Client.getSpace(MetaService.java:516)
at com.vesoft.nebula.client.meta.MetaClient.getSpace(MetaClient.java:228)
at com.vesoft.nebula.connector.nebula.MetaProvider.getVidType(MetaProvider.scala:66)
at com.vesoft.nebula.connector.writer.NebulaWriter.<init>(NebulaWriter.scala:40)
at com.vesoft.nebula.connector.writer.NebulaVertexWriter.<init>(NebulaVertexWriter.scala:18)
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:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
22/02/24 16:16:32 ERROR Executor: Exception in task 0.0 in stage 38.0 (TID 711)
com.facebook.thrift.TApplicationException: Method name getSpace not found
at com.facebook.thrift.TApplicationException.read(TApplicationException.java:133)
at com.vesoft.nebula.meta.MetaService$Client.recv_getSpace(MetaService.java:541)
at com.vesoft.nebula.meta.MetaService$Client.getSpace(MetaService.java:516)
at com.vesoft.nebula.client.meta.MetaClient.getSpace(MetaClient.java:228)
at com.vesoft.nebula.connector.nebula.MetaProvider.getVidType(MetaProvider.scala:66)
at com.vesoft.nebula.connector.writer.NebulaWriter.<init>(NebulaWriter.scala:40)
at com.vesoft.nebula.connector.writer.NebulaVertexWriter.<init>(NebulaVertexWriter.scala:18)
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:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
22/02/24 16:16:32 ERROR TaskSetManager: Task 4 in stage 38.0 failed 1 times; aborting job
22/02/24 16:16:32 ERROR WriteToDataSourceV2Exec: Data source writer com.vesoft.nebula.connector.writer.NebulaDataSourceVertexWriter@184619b8 is aborting.
22/02/24 16:16:32 ERROR NebulaDataSourceVertexWriter: NebulaDataSourceVertexWriter abort
22/02/24 16:16:32 ERROR WriteToDataSourceV2Exec: Data source writer com.vesoft.nebula.connector.writer.NebulaDataSourceVertexWriter@184619b8 aborted.
22/02/24 16:16:33 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:33 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:33 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:33 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:33 ERROR Executor: Exception in task 0.0 in stage 39.0 (TID 731)
com.facebook.thrift.TApplicationException: Method name getSpace not found
at com.facebook.thrift.TApplicationException.read(TApplicationException.java:133)
at com.vesoft.nebula.meta.MetaService$Client.recv_getSpace(MetaService.java:541)
at com.vesoft.nebula.meta.MetaService$Client.getSpace(MetaService.java:516)
at com.vesoft.nebula.client.meta.MetaClient.getSpace(MetaClient.java:228)
at com.vesoft.nebula.connector.nebula.MetaProvider.getVidType(MetaProvider.scala:66)
at com.vesoft.nebula.connector.writer.NebulaWriter.<init>(NebulaWriter.scala:40)
at com.vesoft.nebula.connector.writer.NebulaVertexWriter.<init>(NebulaVertexWriter.scala:18)
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:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
22/02/24 16:16:33 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:33 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:33 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:33 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:33 ERROR TaskSetManager: Task 0 in stage 39.0 failed 1 times; aborting job
22/02/24 16:16:33 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:33 ERROR Executor: Exception in task 2.0 in stage 39.0 (TID 733)
com.facebook.thrift.TApplicationException: Method name getSpace not found
at com.facebook.thrift.TApplicationException.read(TApplicationException.java:133)
at com.vesoft.nebula.meta.MetaService$Client.recv_getSpace(MetaService.java:541)
at com.vesoft.nebula.meta.MetaService$Client.getSpace(MetaService.java:516)
at com.vesoft.nebula.client.meta.MetaClient.getSpace(MetaClient.java:228)
at com.vesoft.nebula.connector.nebula.MetaProvider.getVidType(MetaProvider.scala:66)
at com.vesoft.nebula.connector.writer.NebulaWriter.<init>(NebulaWriter.scala:40)
at com.vesoft.nebula.connector.writer.NebulaVertexWriter.<init>(NebulaVertexWriter.scala:18)
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:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
22/02/24 16:16:33 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:33 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:33 ERROR Executor: Exception in task 3.0 in stage 39.0 (TID 734)
com.facebook.thrift.TApplicationException: Method name getSpace not found
at com.facebook.thrift.TApplicationException.read(TApplicationException.java:133)
at com.vesoft.nebula.meta.MetaService$Client.recv_getSpace(MetaService.java:541)
at com.vesoft.nebula.meta.MetaService$Client.getSpace(MetaService.java:516)
at com.vesoft.nebula.client.meta.MetaClient.getSpace(MetaClient.java:228)
at com.vesoft.nebula.connector.nebula.MetaProvider.getVidType(MetaProvider.scala:66)
at com.vesoft.nebula.connector.writer.NebulaWriter.<init>(NebulaWriter.scala:40)
at com.vesoft.nebula.connector.writer.NebulaVertexWriter.<init>(NebulaVertexWriter.scala:18)
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:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
22/02/24 16:16:33 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:33 ERROR WriteToDataSourceV2Exec: Data source writer com.vesoft.nebula.connector.writer.NebulaDataSourceVertexWriter@6e84d621 is aborting.
22/02/24 16:16:33 ERROR NebulaDataSourceVertexWriter: NebulaDataSourceVertexWriter abort
22/02/24 16:16:33 ERROR WriteToDataSourceV2Exec: Data source writer com.vesoft.nebula.connector.writer.NebulaDataSourceVertexWriter@6e84d621 aborted.
22/02/24 16:16:33 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:33 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:33 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:33 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:33 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:33 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:33 ERROR Executor: Exception in task 0.0 in stage 40.0 (TID 741)
com.facebook.thrift.TApplicationException: Method name getSpace not found
at com.facebook.thrift.TApplicationException.read(TApplicationException.java:133)
at com.vesoft.nebula.meta.MetaService$Client.recv_getSpace(MetaService.java:541)
at com.vesoft.nebula.meta.MetaService$Client.getSpace(MetaService.java:516)
at com.vesoft.nebula.client.meta.MetaClient.getSpace(MetaClient.java:228)
at com.vesoft.nebula.connector.nebula.MetaProvider.getVidType(MetaProvider.scala:66)
at com.vesoft.nebula.connector.writer.NebulaWriter.<init>(NebulaWriter.scala:40)
at com.vesoft.nebula.connector.writer.NebulaVertexWriter.<init>(NebulaVertexWriter.scala:18)
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:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
22/02/24 16:16:33 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:33 ERROR TaskSetManager: Task 0 in stage 40.0 failed 1 times; aborting job
22/02/24 16:16:33 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:33 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:33 ERROR WriteToDataSourceV2Exec: Data source writer com.vesoft.nebula.connector.writer.NebulaDataSourceVertexWriter@4a851238 is aborting.
22/02/24 16:16:33 ERROR NebulaDataSourceVertexWriter: NebulaDataSourceVertexWriter abort
22/02/24 16:16:33 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:33 ERROR WriteToDataSourceV2Exec: Data source writer com.vesoft.nebula.connector.writer.NebulaDataSourceVertexWriter@4a851238 aborted.
22/02/24 16:16:33 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:33 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:33 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:33 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:33 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:33 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:33 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:33 ERROR Executor: Exception in task 3.0 in stage 41.0 (TID 756)
com.facebook.thrift.TApplicationException: Method name getSpace not found
at com.facebook.thrift.TApplicationException.read(TApplicationException.java:133)
at com.vesoft.nebula.meta.MetaService$Client.recv_getSpace(MetaService.java:541)
at com.vesoft.nebula.meta.MetaService$Client.getSpace(MetaService.java:516)
at com.vesoft.nebula.client.meta.MetaClient.getSpace(MetaClient.java:228)
at com.vesoft.nebula.connector.nebula.MetaProvider.getVidType(MetaProvider.scala:66)
at com.vesoft.nebula.connector.writer.NebulaWriter.<init>(NebulaWriter.scala:40)
at com.vesoft.nebula.connector.writer.NebulaVertexWriter.<init>(NebulaVertexWriter.scala:18)
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:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
22/02/24 16:16:33 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:33 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:33 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:33 ERROR Executor: Exception in task 0.0 in stage 41.0 (TID 753)
com.facebook.thrift.TApplicationException: Method name getSpace not found
at com.facebook.thrift.TApplicationException.read(TApplicationException.java:133)
at com.vesoft.nebula.meta.MetaService$Client.recv_getSpace(MetaService.java:541)
at com.vesoft.nebula.meta.MetaService$Client.getSpace(MetaService.java:516)
at com.vesoft.nebula.client.meta.MetaClient.getSpace(MetaClient.java:228)
at com.vesoft.nebula.connector.nebula.MetaProvider.getVidType(MetaProvider.scala:66)
at com.vesoft.nebula.connector.writer.NebulaWriter.<init>(NebulaWriter.scala:40)
at com.vesoft.nebula.connector.writer.NebulaVertexWriter.<init>(NebulaVertexWriter.scala:18)
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:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
22/02/24 16:16:33 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:33 ERROR Executor: Exception in task 2.0 in stage 41.0 (TID 755)
com.facebook.thrift.TApplicationException: Method name getSpace not found
at com.facebook.thrift.TApplicationException.read(TApplicationException.java:133)
at com.vesoft.nebula.meta.MetaService$Client.recv_getSpace(MetaService.java:541)
at com.vesoft.nebula.meta.MetaService$Client.getSpace(MetaService.java:516)
at com.vesoft.nebula.client.meta.MetaClient.getSpace(MetaClient.java:228)
at com.vesoft.nebula.connector.nebula.MetaProvider.getVidType(MetaProvider.scala:66)
at com.vesoft.nebula.connector.writer.NebulaWriter.<init>(NebulaWriter.scala:40)
at com.vesoft.nebula.connector.writer.NebulaVertexWriter.<init>(NebulaVertexWriter.scala:18)
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:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
22/02/24 16:16:33 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:33 ERROR TaskSetManager: Task 3 in stage 41.0 failed 1 times; aborting job
22/02/24 16:16:33 ERROR Executor: Exception in task 1.0 in stage 41.0 (TID 754)
com.facebook.thrift.TApplicationException: Method name getSpace not found
at com.facebook.thrift.TApplicationException.read(TApplicationException.java:133)
at com.vesoft.nebula.meta.MetaService$Client.recv_getSpace(MetaService.java:541)
at com.vesoft.nebula.meta.MetaService$Client.getSpace(MetaService.java:516)
at com.vesoft.nebula.client.meta.MetaClient.getSpace(MetaClient.java:228)
at com.vesoft.nebula.connector.nebula.MetaProvider.getVidType(MetaProvider.scala:66)
at com.vesoft.nebula.connector.writer.NebulaWriter.<init>(NebulaWriter.scala:40)
at com.vesoft.nebula.connector.writer.NebulaVertexWriter.<init>(NebulaVertexWriter.scala:18)
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:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
22/02/24 16:16:33 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:33 ERROR Executor: Exception in task 5.0 in stage 41.0 (TID 758)
com.facebook.thrift.TApplicationException: Method name getSpace not found
at com.facebook.thrift.TApplicationException.read(TApplicationException.java:133)
at com.vesoft.nebula.meta.MetaService$Client.recv_getSpace(MetaService.java:541)
at com.vesoft.nebula.meta.MetaService$Client.getSpace(MetaService.java:516)
at com.vesoft.nebula.client.meta.MetaClient.getSpace(MetaClient.java:228)
at com.vesoft.nebula.connector.nebula.MetaProvider.getVidType(MetaProvider.scala:66)
at com.vesoft.nebula.connector.writer.NebulaWriter.<init>(NebulaWriter.scala:40)
at com.vesoft.nebula.connector.writer.NebulaVertexWriter.<init>(NebulaVertexWriter.scala:18)
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:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
22/02/24 16:16:33 ERROR WriteToDataSourceV2Exec: Data source writer com.vesoft.nebula.connector.writer.NebulaDataSourceVertexWriter@5f7b7f0 is aborting.
22/02/24 16:16:33 ERROR NebulaDataSourceVertexWriter: NebulaDataSourceVertexWriter abort
22/02/24 16:16:33 ERROR WriteToDataSourceV2Exec: Data source writer com.vesoft.nebula.connector.writer.NebulaDataSourceVertexWriter@5f7b7f0 aborted.
22/02/24 16:16:33 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:33 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:33 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:33 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:33 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:33 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:33 ERROR Executor: Exception in task 0.0 in stage 42.0 (TID 767)
com.facebook.thrift.TApplicationException: Method name getSpace not found
at com.facebook.thrift.TApplicationException.read(TApplicationException.java:133)
at com.vesoft.nebula.meta.MetaService$Client.recv_getSpace(MetaService.java:541)
at com.vesoft.nebula.meta.MetaService$Client.getSpace(MetaService.java:516)
at com.vesoft.nebula.client.meta.MetaClient.getSpace(MetaClient.java:228)
at com.vesoft.nebula.connector.nebula.MetaProvider.getVidType(MetaProvider.scala:66)
at com.vesoft.nebula.connector.writer.NebulaWriter.<init>(NebulaWriter.scala:40)
at com.vesoft.nebula.connector.writer.NebulaVertexWriter.<init>(NebulaVertexWriter.scala:18)
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:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
22/02/24 16:16:33 ERROR TaskSetManager: Task 0 in stage 42.0 failed 1 times; aborting job
22/02/24 16:16:33 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:33 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:33 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:33 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:33 ERROR WriteToDataSourceV2Exec: Data source writer com.vesoft.nebula.connector.writer.NebulaDataSourceVertexWriter@86ff882 is aborting.
22/02/24 16:16:33 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:33 ERROR NebulaDataSourceVertexWriter: NebulaDataSourceVertexWriter abort
22/02/24 16:16:33 ERROR WriteToDataSourceV2Exec: Data source writer com.vesoft.nebula.connector.writer.NebulaDataSourceVertexWriter@86ff882 aborted.
22/02/24 16:16:33 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:33 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:34 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:34 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:34 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:34 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:34 ERROR Executor: Exception in task 4.0 in stage 43.0 (TID 780)
com.facebook.thrift.TApplicationException: Method name getSpace not found
at com.facebook.thrift.TApplicationException.read(TApplicationException.java:133)
at com.vesoft.nebula.meta.MetaService$Client.recv_getSpace(MetaService.java:541)
at com.vesoft.nebula.meta.MetaService$Client.getSpace(MetaService.java:516)
at com.vesoft.nebula.client.meta.MetaClient.getSpace(MetaClient.java:228)
at com.vesoft.nebula.connector.nebula.MetaProvider.getVidType(MetaProvider.scala:66)
at com.vesoft.nebula.connector.writer.NebulaWriter.<init>(NebulaWriter.scala:40)
at com.vesoft.nebula.connector.writer.NebulaVertexWriter.<init>(NebulaVertexWriter.scala:18)
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:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
22/02/24 16:16:34 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:34 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:34 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:34 ERROR Executor: Exception in task 3.0 in stage 43.0 (TID 779)
com.facebook.thrift.TApplicationException: Method name getSpace not found
at com.facebook.thrift.TApplicationException.read(TApplicationException.java:133)
at com.vesoft.nebula.meta.MetaService$Client.recv_getSpace(MetaService.java:541)
at com.vesoft.nebula.meta.MetaService$Client.getSpace(MetaService.java:516)
at com.vesoft.nebula.client.meta.MetaClient.getSpace(MetaClient.java:228)
at com.vesoft.nebula.connector.nebula.MetaProvider.getVidType(MetaProvider.scala:66)
at com.vesoft.nebula.connector.writer.NebulaWriter.<init>(NebulaWriter.scala:40)
at com.vesoft.nebula.connector.writer.NebulaVertexWriter.<init>(NebulaVertexWriter.scala:18)
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:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
22/02/24 16:16:34 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:34 ERROR Executor: Exception in task 0.0 in stage 43.0 (TID 776)
com.facebook.thrift.TApplicationException: Method name getSpace not found
at com.facebook.thrift.TApplicationException.read(TApplicationException.java:133)
at com.vesoft.nebula.meta.MetaService$Client.recv_getSpace(MetaService.java:541)
at com.vesoft.nebula.meta.MetaService$Client.getSpace(MetaService.java:516)
at com.vesoft.nebula.client.meta.MetaClient.getSpace(MetaClient.java:228)
at com.vesoft.nebula.connector.nebula.MetaProvider.getVidType(MetaProvider.scala:66)
at com.vesoft.nebula.connector.writer.NebulaWriter.<init>(NebulaWriter.scala:40)
at com.vesoft.nebula.connector.writer.NebulaVertexWriter.<init>(NebulaVertexWriter.scala:18)
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:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
22/02/24 16:16:34 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:34 ERROR TaskSetManager: Task 4 in stage 43.0 failed 1 times; aborting job
22/02/24 16:16:34 ERROR Executor: Exception in task 2.0 in stage 43.0 (TID 778)
com.facebook.thrift.TApplicationException: Method name getSpace not found
at com.facebook.thrift.TApplicationException.read(TApplicationException.java:133)
at com.vesoft.nebula.meta.MetaService$Client.recv_getSpace(MetaService.java:541)
at com.vesoft.nebula.meta.MetaService$Client.getSpace(MetaService.java:516)
at com.vesoft.nebula.client.meta.MetaClient.getSpace(MetaClient.java:228)
at com.vesoft.nebula.connector.nebula.MetaProvider.getVidType(MetaProvider.scala:66)
at com.vesoft.nebula.connector.writer.NebulaWriter.<init>(NebulaWriter.scala:40)
at com.vesoft.nebula.connector.writer.NebulaVertexWriter.<init>(NebulaVertexWriter.scala:18)
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:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
22/02/24 16:16:34 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:34 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:34 ERROR Executor: Exception in task 1.0 in stage 43.0 (TID 777)
com.facebook.thrift.TApplicationException: Method name getSpace not found
at com.facebook.thrift.TApplicationException.read(TApplicationException.java:133)
at com.vesoft.nebula.meta.MetaService$Client.recv_getSpace(MetaService.java:541)
at com.vesoft.nebula.meta.MetaService$Client.getSpace(MetaService.java:516)
at com.vesoft.nebula.client.meta.MetaClient.getSpace(MetaClient.java:228)
at com.vesoft.nebula.connector.nebula.MetaProvider.getVidType(MetaProvider.scala:66)
at com.vesoft.nebula.connector.writer.NebulaWriter.<init>(NebulaWriter.scala:40)
at com.vesoft.nebula.connector.writer.NebulaVertexWriter.<init>(NebulaVertexWriter.scala:18)
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:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
22/02/24 16:16:34 ERROR Executor: Exception in task 6.0 in stage 43.0 (TID 782)
com.facebook.thrift.TApplicationException: Method name getSpace not found
at com.facebook.thrift.TApplicationException.read(TApplicationException.java:133)
at com.vesoft.nebula.meta.MetaService$Client.recv_getSpace(MetaService.java:541)
at com.vesoft.nebula.meta.MetaService$Client.getSpace(MetaService.java:516)
at com.vesoft.nebula.client.meta.MetaClient.getSpace(MetaClient.java:228)
at com.vesoft.nebula.connector.nebula.MetaProvider.getVidType(MetaProvider.scala:66)
at com.vesoft.nebula.connector.writer.NebulaWriter.<init>(NebulaWriter.scala:40)
at com.vesoft.nebula.connector.writer.NebulaVertexWriter.<init>(NebulaVertexWriter.scala:18)
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:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
22/02/24 16:16:34 ERROR WriteToDataSourceV2Exec: Data source writer com.vesoft.nebula.connector.writer.NebulaDataSourceVertexWriter@565e138 is aborting.
22/02/24 16:16:34 ERROR NebulaDataSourceVertexWriter: NebulaDataSourceVertexWriter abort
22/02/24 16:16:34 ERROR WriteToDataSourceV2Exec: Data source writer com.vesoft.nebula.connector.writer.NebulaDataSourceVertexWriter@565e138 aborted.
22/02/24 16:16:34 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:34 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:34 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:34 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:34 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:34 ERROR Executor: Exception in task 6.0 in stage 44.0 (TID 794)
com.facebook.thrift.TApplicationException: Method name getSpace not found
at com.facebook.thrift.TApplicationException.read(TApplicationException.java:133)
at com.vesoft.nebula.meta.MetaService$Client.recv_getSpace(MetaService.java:541)
at com.vesoft.nebula.meta.MetaService$Client.getSpace(MetaService.java:516)
at com.vesoft.nebula.client.meta.MetaClient.getSpace(MetaClient.java:228)
at com.vesoft.nebula.connector.nebula.MetaProvider.getVidType(MetaProvider.scala:66)
at com.vesoft.nebula.connector.writer.NebulaWriter.<init>(NebulaWriter.scala:40)
at com.vesoft.nebula.connector.writer.NebulaVertexWriter.<init>(NebulaVertexWriter.scala:18)
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:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
22/02/24 16:16:34 ERROR TaskSetManager: Task 6 in stage 44.0 failed 1 times; aborting job
22/02/24 16:16:34 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:34 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:34 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:34 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:34 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:34 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:34 ERROR WriteToDataSourceV2Exec: Data source writer com.vesoft.nebula.connector.writer.NebulaDataSourceVertexWriter@3cdbb57 is aborting.
22/02/24 16:16:34 ERROR NebulaDataSourceVertexWriter: NebulaDataSourceVertexWriter abort
22/02/24 16:16:34 ERROR WriteToDataSourceV2Exec: Data source writer com.vesoft.nebula.connector.writer.NebulaDataSourceVertexWriter@3cdbb57 aborted.
22/02/24 16:16:34 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:34 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:34 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:34 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:34 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:34 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:34 ERROR Executor: Exception in task 1.0 in stage 45.0 (TID 800)
com.facebook.thrift.TApplicationException: Method name getSpace not found
at com.facebook.thrift.TApplicationException.read(TApplicationException.java:133)
at com.vesoft.nebula.meta.MetaService$Client.recv_getSpace(MetaService.java:541)
at com.vesoft.nebula.meta.MetaService$Client.getSpace(MetaService.java:516)
at com.vesoft.nebula.client.meta.MetaClient.getSpace(MetaClient.java:228)
at com.vesoft.nebula.connector.nebula.MetaProvider.getVidType(MetaProvider.scala:66)
at com.vesoft.nebula.connector.writer.NebulaWriter.<init>(NebulaWriter.scala:40)
at com.vesoft.nebula.connector.writer.NebulaVertexWriter.<init>(NebulaVertexWriter.scala:18)
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:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
22/02/24 16:16:34 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:34 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:34 ERROR Executor: Exception in task 2.0 in stage 45.0 (TID 801)
com.facebook.thrift.TApplicationException: Method name getSpace not found
at com.facebook.thrift.TApplicationException.read(TApplicationException.java:133)
at com.vesoft.nebula.meta.MetaService$Client.recv_getSpace(MetaService.java:541)
at com.vesoft.nebula.meta.MetaService$Client.getSpace(MetaService.java:516)
at com.vesoft.nebula.client.meta.MetaClient.getSpace(MetaClient.java:228)
at com.vesoft.nebula.connector.nebula.MetaProvider.getVidType(MetaProvider.scala:66)
at com.vesoft.nebula.connector.writer.NebulaWriter.<init>(NebulaWriter.scala:40)
at com.vesoft.nebula.connector.writer.NebulaVertexWriter.<init>(NebulaVertexWriter.scala:18)
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:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
22/02/24 16:16:34 ERROR Executor: Exception in task 0.0 in stage 45.0 (TID 799)
com.facebook.thrift.TApplicationException: Method name getSpace not found
at com.facebook.thrift.TApplicationException.read(TApplicationException.java:133)
at com.vesoft.nebula.meta.MetaService$Client.recv_getSpace(MetaService.java:541)
at com.vesoft.nebula.meta.MetaService$Client.getSpace(MetaService.java:516)
at com.vesoft.nebula.client.meta.MetaClient.getSpace(MetaClient.java:228)
at com.vesoft.nebula.connector.nebula.MetaProvider.getVidType(MetaProvider.scala:66)
at com.vesoft.nebula.connector.writer.NebulaWriter.<init>(NebulaWriter.scala:40)
at com.vesoft.nebula.connector.writer.NebulaVertexWriter.<init>(NebulaVertexWriter.scala:18)
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:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
22/02/24 16:16:34 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:34 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:34 ERROR Executor: Exception in task 6.0 in stage 45.0 (TID 805)
com.facebook.thrift.TApplicationException: Method name getSpace not found
at com.facebook.thrift.TApplicationException.read(TApplicationException.java:133)
at com.vesoft.nebula.meta.MetaService$Client.recv_getSpace(MetaService.java:541)
at com.vesoft.nebula.meta.MetaService$Client.getSpace(MetaService.java:516)
at com.vesoft.nebula.client.meta.MetaClient.getSpace(MetaClient.java:228)
at com.vesoft.nebula.connector.nebula.MetaProvider.getVidType(MetaProvider.scala:66)
at com.vesoft.nebula.connector.writer.NebulaWriter.<init>(NebulaWriter.scala:40)
at com.vesoft.nebula.connector.writer.NebulaVertexWriter.<init>(NebulaVertexWriter.scala:18)
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:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
22/02/24 16:16:34 ERROR Executor: Exception in task 5.0 in stage 45.0 (TID 804)
com.facebook.thrift.TApplicationException: Method name getSpace not found
at com.facebook.thrift.TApplicationException.read(TApplicationException.java:133)
at com.vesoft.nebula.meta.MetaService$Client.recv_getSpace(MetaService.java:541)
at com.vesoft.nebula.meta.MetaService$Client.getSpace(MetaService.java:516)
at com.vesoft.nebula.client.meta.MetaClient.getSpace(MetaClient.java:228)
at com.vesoft.nebula.connector.nebula.MetaProvider.getVidType(MetaProvider.scala:66)
at com.vesoft.nebula.connector.writer.NebulaWriter.<init>(NebulaWriter.scala:40)
at com.vesoft.nebula.connector.writer.NebulaVertexWriter.<init>(NebulaVertexWriter.scala:18)
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:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
22/02/24 16:16:34 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:34 ERROR Executor: Exception in task 7.0 in stage 45.0 (TID 806)
com.facebook.thrift.TApplicationException: Method name getSpace not found
at com.facebook.thrift.TApplicationException.read(TApplicationException.java:133)
at com.vesoft.nebula.meta.MetaService$Client.recv_getSpace(MetaService.java:541)
at com.vesoft.nebula.meta.MetaService$Client.getSpace(MetaService.java:516)
at com.vesoft.nebula.client.meta.MetaClient.getSpace(MetaClient.java:228)
at com.vesoft.nebula.connector.nebula.MetaProvider.getVidType(MetaProvider.scala:66)
at com.vesoft.nebula.connector.writer.NebulaWriter.<init>(NebulaWriter.scala:40)
at com.vesoft.nebula.connector.writer.NebulaVertexWriter.<init>(NebulaVertexWriter.scala:18)
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:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
22/02/24 16:16:34 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:34 ERROR TaskSetManager: Task 2 in stage 45.0 failed 1 times; aborting job
22/02/24 16:16:34 ERROR Executor: Exception in task 4.0 in stage 45.0 (TID 803)
com.facebook.thrift.TApplicationException: Method name getSpace not found
at com.facebook.thrift.TApplicationException.read(TApplicationException.java:133)
at com.vesoft.nebula.meta.MetaService$Client.recv_getSpace(MetaService.java:541)
at com.vesoft.nebula.meta.MetaService$Client.getSpace(MetaService.java:516)
at com.vesoft.nebula.client.meta.MetaClient.getSpace(MetaClient.java:228)
at com.vesoft.nebula.connector.nebula.MetaProvider.getVidType(MetaProvider.scala:66)
at com.vesoft.nebula.connector.writer.NebulaWriter.<init>(NebulaWriter.scala:40)
at com.vesoft.nebula.connector.writer.NebulaVertexWriter.<init>(NebulaVertexWriter.scala:18)
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:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
22/02/24 16:16:34 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:34 ERROR Executor: Exception in task 3.0 in stage 45.0 (TID 802)
com.facebook.thrift.TApplicationException: Method name getSpace not found
at com.facebook.thrift.TApplicationException.read(TApplicationException.java:133)
at com.vesoft.nebula.meta.MetaService$Client.recv_getSpace(MetaService.java:541)
at com.vesoft.nebula.meta.MetaService$Client.getSpace(MetaService.java:516)
at com.vesoft.nebula.client.meta.MetaClient.getSpace(MetaClient.java:228)
at com.vesoft.nebula.connector.nebula.MetaProvider.getVidType(MetaProvider.scala:66)
at com.vesoft.nebula.connector.writer.NebulaWriter.<init>(NebulaWriter.scala:40)
at com.vesoft.nebula.connector.writer.NebulaVertexWriter.<init>(NebulaVertexWriter.scala:18)
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:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
22/02/24 16:16:34 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:34 ERROR WriteToDataSourceV2Exec: Data source writer com.vesoft.nebula.connector.writer.NebulaDataSourceVertexWriter@4e7bf371 is aborting.
22/02/24 16:16:34 ERROR NebulaDataSourceVertexWriter: NebulaDataSourceVertexWriter abort
22/02/24 16:16:34 ERROR WriteToDataSourceV2Exec: Data source writer com.vesoft.nebula.connector.writer.NebulaDataSourceVertexWriter@4e7bf371 aborted.
Exception in thread "main" org.apache.spark.SparkException: Writing job aborted.
at org.apache.spark.sql.execution.datasources.v2.WriteToDataSourceV2Exec.doExecute(WriteToDataSourceV2Exec.scala:92)
at org.apache.spark.sql.execution.SparkPlan$$anonfun$execute$1.apply(SparkPlan.scala:131)
at org.apache.spark.sql.execution.SparkPlan$$anonfun$execute$1.apply(SparkPlan.scala:127)
at org.apache.spark.sql.execution.SparkPlan$$anonfun$executeQuery$1.apply(SparkPlan.scala:155)
at org.apache.spark.rdd.RDDOperationScope$.withScope(RDDOperationScope.scala:151)
at org.apache.spark.sql.execution.SparkPlan.executeQuery(SparkPlan.scala:152)
at org.apache.spark.sql.execution.SparkPlan.execute(SparkPlan.scala:127)
at org.apache.spark.sql.execution.QueryExecution.toRdd$lzycompute(QueryExecution.scala:83)
at org.apache.spark.sql.execution.QueryExecution.toRdd(QueryExecution.scala:81)
at org.apache.spark.sql.DataFrameWriter$$anonfun$runCommand$1.apply(DataFrameWriter.scala:676)
at org.apache.spark.sql.DataFrameWriter$$anonfun$runCommand$1.apply(DataFrameWriter.scala:676)
at org.apache.spark.sql.execution.SQLExecution$$anonfun$withNewExecutionId$1.apply(SQLExecution.scala:80)
at org.apache.spark.sql.execution.SQLExecution$.withSQLConfPropagated(SQLExecution.scala:127)
at org.apache.spark.sql.execution.SQLExecution$.withNewExecutionId(SQLExecution.scala:75)
at org.apache.spark.sql.DataFrameWriter.runCommand(DataFrameWriter.scala:676)
at org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:260)
at com.vesoft.nebula.connector.connector.package$NebulaDataFrameWriter.writeVertices(package.scala:287)
at net.qihoo.function.write.WriteData.writeVertices(WriteData.scala:9)
at net.qihoo.function.write.Write2Nebula.writeVertex(Write2Nebula.java:109)
at net.qihoo.function.write.Write2Nebula.lambda$write2Nebula$8(Write2Nebula.java:155)
at java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
at java.util.HashMap$EntrySpliterator.forEachRemaining(HashMap.java:1699)
at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482)
at java.util.stream.ForEachOps$ForEachTask.compute(ForEachOps.java:290)
at java.util.concurrent.CountedCompleter.exec(CountedCompleter.java:731)
at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056)
at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692)
at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175)
Caused by: org.apache.spark.SparkException: Job aborted due to stage failure: Task 4 in stage 38.0 failed 1 times, most recent failure: Lost task 4.0 in stage 38.0 (TID 715, localhost, executor driver): com.facebook.thrift.TApplicationException: Method name getSpace not found
at com.facebook.thrift.TApplicationException.read(TApplicationException.java:133)
at com.vesoft.nebula.meta.MetaService$Client.recv_getSpace(MetaService.java:541)
at com.vesoft.nebula.meta.MetaService$Client.getSpace(MetaService.java:516)
at com.vesoft.nebula.client.meta.MetaClient.getSpace(MetaClient.java:228)
at com.vesoft.nebula.connector.nebula.MetaProvider.getVidType(MetaProvider.scala:66)
at com.vesoft.nebula.connector.writer.NebulaWriter.<init>(NebulaWriter.scala:40)
at com.vesoft.nebula.connector.writer.NebulaVertexWriter.<init>(NebulaVertexWriter.scala:18)
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:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
Driver stacktrace:
at org.apache.spark.scheduler.DAGScheduler.org$apache$spark$scheduler$DAGScheduler$$failJobAndIndependentStages(DAGScheduler.scala:1891)
at org.apache.spark.scheduler.DAGScheduler$$anonfun$abortStage$1.apply(DAGScheduler.scala:1879)
at org.apache.spark.scheduler.DAGScheduler$$anonfun$abortStage$1.apply(DAGScheduler.scala:1878)
at scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:59)
at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:48)
at org.apache.spark.scheduler.DAGScheduler.abortStage(DAGScheduler.scala:1878)
at org.apache.spark.scheduler.DAGScheduler$$anonfun$handleTaskSetFailed$1.apply(DAGScheduler.scala:927)
at org.apache.spark.scheduler.DAGScheduler$$anonfun$handleTaskSetFailed$1.apply(DAGScheduler.scala:927)
at scala.Option.foreach(Option.scala:257)
at org.apache.spark.scheduler.DAGScheduler.handleTaskSetFailed(DAGScheduler.scala:927)
at org.apache.spark.scheduler.DAGSchedulerEventProcessLoop.doOnReceive(DAGScheduler.scala:2112)
at org.apache.spark.scheduler.DAGSchedulerEventProcessLoop.onReceive(DAGScheduler.scala:2061)
at org.apache.spark.scheduler.DAGSchedulerEventProcessLoop.onReceive(DAGScheduler.scala:2050)
at org.apache.spark.util.EventLoop$$anon$1.run(EventLoop.scala:49)
at org.apache.spark.scheduler.DAGScheduler.runJob(DAGScheduler.scala:738)
at org.apache.spark.SparkContext.runJob(SparkContext.scala:2061)
at org.apache.spark.sql.execution.datasources.v2.WriteToDataSourceV2Exec.doExecute(WriteToDataSourceV2Exec.scala:64)
... 28 more
Caused by: com.facebook.thrift.TApplicationException: Method name getSpace not found
at com.facebook.thrift.TApplicationException.read(TApplicationException.java:133)
at com.vesoft.nebula.meta.MetaService$Client.recv_getSpace(MetaService.java:541)
at com.vesoft.nebula.meta.MetaService$Client.getSpace(MetaService.java:516)
at com.vesoft.nebula.client.meta.MetaClient.getSpace(MetaClient.java:228)
at com.vesoft.nebula.connector.nebula.MetaProvider.getVidType(MetaProvider.scala:66)
at com.vesoft.nebula.connector.writer.NebulaWriter.<init>(NebulaWriter.scala:40)
at com.vesoft.nebula.connector.writer.NebulaVertexWriter.<init>(NebulaVertexWriter.scala:18)
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:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
22/02/24 16:16:34 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:34 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:34 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:35 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:35 ERROR Executor: Exception in task 1.0 in stage 46.0 (TID 813)
com.facebook.thrift.TApplicationException: Method name getSpace not found
at com.facebook.thrift.TApplicationException.read(TApplicationException.java:133)
at com.vesoft.nebula.meta.MetaService$Client.recv_getSpace(MetaService.java:541)
at com.vesoft.nebula.meta.MetaService$Client.getSpace(MetaService.java:516)
at com.vesoft.nebula.client.meta.MetaClient.getSpace(MetaClient.java:228)
at com.vesoft.nebula.connector.nebula.MetaProvider.getVidType(MetaProvider.scala:66)
at com.vesoft.nebula.connector.writer.NebulaWriter.<init>(NebulaWriter.scala:40)
at com.vesoft.nebula.connector.writer.NebulaVertexWriter.<init>(NebulaVertexWriter.scala:18)
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:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
22/02/24 16:16:35 ERROR MetaClient: Get Space Error: Method name getSpace not found
22/02/24 16:16:35 ERROR TaskSetManager: Task 1 in stage 46.0 failed 1 times; aborting job
22/02/24 16:16:35 ERROR Executor: Exception in task 0.0 in stage 46.0 (TID 812)
com.facebook.thrift.TApplicationException: Method name getSpace not found
at com.facebook.thrift.TApplicationException.read(TApplicationException.java:133)
at com.vesoft.nebula.meta.MetaService$Client.recv_getSpace(MetaService.java:541)
at com.vesoft.nebula.meta.MetaService$Client.getSpace(MetaService.java:516)
at com.vesoft.nebula.client.meta.MetaClient.getSpace(MetaClient.java:228)
at com.vesoft.nebula.connector.nebula.MetaProvider.getVidType(MetaProvider.scala:66)
at com.vesoft.nebula.connector.writer.NebulaWriter.<init>(NebulaWriter.scala:40)
at com.vesoft.nebula.connector.writer.NebulaVertexWriter.<init>(NebulaVertexWriter.scala:18)
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:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
Emm，我要问个基础题了，你 Space 和 Schema 创建过吗
创建了 ，不创建也插入不进去部分数据呀
通过studio都能查出来，插入一半就开始链接超时，测试数据流也不大一共100条
我有很多种tag 是不是因为我遍历tag分别插入引起的啊
地址这样的格式是对的 “127.0.0.1:9559,127.0.0.1:9560”
meta的域名格式需要spark 2.6.2 以上才支持（最近才fix 了不支持域名形式的问题）
如果是 docker-compose，需要让 spark 运行在 容器网络内，最好用 容器跑 spark 指定相同的容器网络：
这是我的一个例子：
docker run --name spark-master --network nebula-docker-compose_nebula-net \
-h spark-master -e ENABLE_INIT_DAEMON=false -d \
-v nebula-algorithm/:/root \
bde2020/spark-master:2.4.5-hadoop2.7
1 个赞
请问 spark 运行在容器网络 nebula-net 么？
可能是无法访问metaclient（spark 客户端读是扫 storage，用途和其他客户端不同-读写都是graphd，spark-connector 读数据需要 metaclient 和 storageclient），因为写路径只需要 graphD、graphclient，而默认不在容器网络里，默认compose的配置下，只有 一个 graphD 外部可以连接
1 个赞
-
@wey 的观点是正确的，spark 和 nebula 需要在同一个 network 中， 这样才能通过compose文件中的服务名进行访问。
但是关注到 @chenpeng 的描述：数据库中已经成功插入了部分测试数据，但是后续部分报错。如果配置出错的情况下是不是应该所有数据都不会插入。或许需要看下是不是还有什么其它原因导致的。 -
关于 “有时候还有这个错误 ERROR MetaClient: Get Space Error: Method name getSpace not found”
- 图空间创建是异步实现的，创建完成时立刻尝试使用是可能会失败，官方文档描述需要等待 2 个心跳周期（20 秒），这个错误会不会是这个原因导致的 @chenpeng
2 个赞
，这个应该是关键，不过，看起来不是 Space 找不到，而是 getSpace 方法找不到。
我怀疑是把不是 meta 的 endpoint 填到了 metaD client addess 里，因为不是 metaD，所以这个 thrift RPC function 不存在。
不是的，不是运行在容器
这样不行的，因为只要读数据，spark connector 就需要访问 storaged 和 metad，而且，最棘手的问题在于，storageD 的地址是从 metaD 获取的，不是手动指定的，所以在容器内部按照 compose 默认配置，获取的 地址是 storaged0:9779 这样的，外部的 spark 没法访问
详细信息我在这个视频里有提及。 新手玩转 Nebula vol. 12: 如何在 K8s 部署的集群里连接 Nebula Spark Connector & Nebula.Algorithm_哔哩哔哩_bilibili
方案：
- 不使用 docker ，用 rpm/deb部署neblua
- 修改 compose 配置，让 storage/meta 的地址内外部同时外部可访问
- 把spark 跑在容器里，在一个容器网络（最容易）
1 个赞
此话题已在最后回复的 30 天后被自动关闭。不再允许新回复。