spark 写入数据报错 能插入部分数据

nebula版本:3.0
服务器配置:4vCPU 32GB nvme_ssd500GB *3

依赖版本:
<spark.scala.version>2.11</spark.scala.version>
<spark.version>2.4.5</spark.version>
<nebula.spark.connector>3.0.0</nebula.spark.connector>

show hosts;

172.16.8.15	9779	ONLINE	99	test:33, test1:33, test2:33	test:33, test1:33, test2:33	3.0.0
172.16.8.176	9779	ONLINE	102	test:34, test1:34, test2:34	test:34, test1:34, test2:34	3.0.0
172.16.10.149	9779	ONLINE	99	test:33, test1:33, test2:33	test:33, test1:33, test2:33	3.0.0

日志:

22/02/24 14:36:13 ERROR Executor: Exception in task 77.0 in stage 140.0 (TID 8835)
com.facebook.thrift.transport.TTransportException: java.net.ConnectException: Can't assign requested address (connect failed)
	at com.facebook.thrift.transport.TSocket.open(TSocket.java:206)
	at com.vesoft.nebula.client.meta.MetaClient.getClient(MetaClient.java:148)
	at com.vesoft.nebula.client.meta.MetaClient.doConnect(MetaClient.java:127)
	at com.vesoft.nebula.client.meta.MetaClient.connect(MetaClient.java:116)
	at com.vesoft.nebula.connector.nebula.MetaProvider.<init>(MetaProvider.scala:53)
	at com.vesoft.nebula.connector.writer.NebulaWriter.<init>(NebulaWriter.scala:22)
	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)
Caused by: java.net.ConnectException: Can't assign requested address (connect failed)
	at java.net.PlainSocketImpl.socketConnect(Native Method)
	at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:350)
	at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206)
	at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188)
	at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
	at java.net.Socket.connect(Socket.java:607)
	at com.facebook.thrift.transport.TSocket.open(TSocket.java:201)
	... 18 more
22/02/24 14:36:13 ERROR Executor: Exception in task 76.0 in stage 140.0 (TID 8834)
com.facebook.thrift.transport.TTransportException: java.net.ConnectException: Can't assign requested address (connect failed)
	at com.facebook.thrift.transport.TSocket.open(TSocket.java:206)
	at com.vesoft.nebula.client.meta.MetaClient.getClient(MetaClient.java:148)
	at com.vesoft.nebula.client.meta.MetaClient.doConnect(MetaClient.java:127)
	at com.vesoft.nebula.client.meta.MetaClient.connect(MetaClient.java:116)
	at com.vesoft.nebula.connector.nebula.MetaProvider.<init>(MetaProvider.scala:53)
	at com.vesoft.nebula.connector.writer.NebulaWriter.<init>(NebulaWriter.scala:22)
	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)
Caused by: java.net.ConnectException: Can't assign requested address (connect failed)
	at java.net.PlainSocketImpl.socketConnect(Native Method)
	at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:350)
	at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206)
	at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188)
	at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
	at java.net.Socket.connect(Socket.java:607)
	at com.facebook.thrift.transport.TSocket.open(TSocket.java:201)
	... 18 more
22/02/24 14:36:14 ERROR TaskSetManager: Task 7 in stage 199.0 failed 1 times; aborting job
22/02/24 14:36:14 ERROR WriteToDataSourceV2Exec: Data source writer com.vesoft.nebula.connector.writer.NebulaDataSourceVertexWriter@7d18d0f3 is aborting.
22/02/24 14:36:14 ERROR NebulaDataSourceVertexWriter: NebulaDataSourceVertexWriter abort
22/02/24 14:36:14 ERROR WriteToDataSourceV2Exec: Data source writer com.vesoft.nebula.connector.writer.NebulaDataSourceVertexWriter@7d18d0f3 aborted.

你贴下 spark connector 那边的配置

NebulaConnectionConfig config = NebulaConnectionConfig.builder()
                .withMetaAddress("node01:9559,node02:9559,node03:9559")
                .withGraphAddress("node01:9669,node02:9669,node03:9669")
                .withConenctionRetry(10)
                .withTimeout(20000)
                .withExecuteRetry(3)
                .build();

“ip:端口号”,“ip:端口号”,“ip:端口号”

“ip:端口号”,“ip:端口号”,“ip:端口号”,多个地址的话,填写方式是这样的,你把 meta 和 graph 的地址重新填一下,双引号用逗号分开

不不,我是说,你是 “ip1:port1,ip2:port2,ip3:port3” 还是 “ip1:port1”,“ip2:port2”,“ip3:port3”


这个方法参数入参是一个String,我传入多个不行吧

试试

“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” 这个,:thinking: 你确认所有的 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条

:thinking: java-client 报错“Method Name xxx not found” 按照之前的帖子的话,你是不是端口配置没配置好。

我有很多种tag 是不是因为我遍历tag分别插入引起的啊