通过spark批量导入报错-1002

[lijinpeng]

com.facebook.thrift.protocol.TProtocolException: The field ‘error_code’ has been assigned the invalid value -1002
at com.vesoft.nebula.graph.ExecutionResponse.validate(ExecutionResponse.java:932)
at com.vesoft.nebula.graph.ExecutionResponse.read(ExecutionResponse.java:745)
at com.vesoft.nebula.graph.GraphService$execute_result.read(GraphService.java:1809)
at com.vesoft.nebula.graph.GraphService$Client.recv_execute(GraphService.java:184)
at com.vesoft.nebula.graph.GraphService$AsyncClient$execute_call.getResult(GraphService.java:309)
at com.vesoft.nebula.client.graph.async.entry.ExecuteCallback.doComplete(ExecuteCallback.java:13)
at com.vesoft.nebula.entry.AbstractNebulaCallback.onComplete(AbstractNebulaCallback.java:39)
at com.facebook.thrift.async.TAsyncMethodCall.cleanUpAndFireCallback(TAsyncMethodCall.java:226)
at com.facebook.thrift.async.TAsyncMethodCall.doReadingResponseBody(TAsyncMethodCall.java:216)
at com.facebook.thrift.async.TAsyncMethodCall.transition(TAsyncMethodCall.java:192)
at com.facebook.thrift.async.TAsyncClientManager$SelectThread.transitionMethods(TAsyncClientManager.java:137)
at com.facebook.thrift.async.TAsyncClientManager$SelectThread.run(TAsyncClientManager.java:113)

[dcdd7]

同问 我也有这个问题

[nicole]

@lijinpeng

com.facebook.thrift.protocol.TProtocolException: The field ‘error_code’ has been assigned the invalid value -1002

版本不匹配，请按照readme中给出的版本对应关系使用。

[lijinpeng]

请问这个版本对应关系，在哪里查到？

[lijinpeng]

我现在nebula的版本是2.5.1，想通过spark任务把hive表的数据写入到nebula中，应该如何处理？

[nicole]

@nicole

版本不匹配，请按照readme中给出的版本对应关系使用。

readme看一下？

[lijinpeng]

是否可以加个联系方式？确实有急事想问 我的手机号：–，也可以通过这个手机号加微信 感谢！！！

[steam]

手机号我编辑掉了，在公开的场所放出来不大安全，以及我们倡导开放的交流环境，不提倡 1v1 的私聊，因为不利于其他人员参与参考、看到已有的解决方案。

[lijinpeng]

有没有官方交流群，可以加入？

[nicole]

你的问题很简单啊， 为啥不去repo的readme 看下版本对应关系呢。GitHub - vesoft-inc/nebula-spark-connector

你用2.5.1的nebula，那就用2.5.0或者2.5.1的nebula-spark-connector就好了呀。

你想把hive数据导入nebula，那就先用spark把hive数据读出来（读出来是DataFrame），然后参考example中的代码示例或者readme中的示例就可以把hive数据写入Nebula了啊。