nebula_spark_connector pyspark api 写入边报错 java.lang.NullPointerException（写入点的时候没有报错）

[MJ1]

    nebula 版本：v3.2.0 
    部署方式：分布式 
    安装方式： RPM 
    是否为线上版本：Y 
    spark 版本：2.4.3
    python 版本：3.7
    nebula_spark_connector 版本：3.0.0

[wey]

像是缺了某一个 option，可以试着填一下 writeMode ?

cc @nicole

[MJ1]

后来加上了，还是同样的问题

[MJ1]

下面是写入点的option 是没有问题的

[wey]

@Reid00 请问你写过边么？

[Reid00]

• 少个 .option("rankFiled", "")\ 对于边而言rankFeild 是必填的，没有的话保持空字符串。
• 对于edge 而言应该是没有vidPolicy 字段的，这个你写了 可能会报错吧

[wey]

感谢，这里还有一个错字，我提 pr 了，回头合并之后注意一下变化哈

[Reid00]

我上次好像也看到了一个错误，是这里吗？
https://github.com/vesoft-inc/nebula-spark-connector/blob/6b80a2ff9d481abb89307f8f18ca5580256d5f2d/nebula-spark-connector/src/main/scala/com/vesoft/nebula/connector/NebulaOptions.scala#L223

[wey]

Opps, 这里之前我还没发现，这次只发现了 rankfiled/rankfield。

chore: typo fix of rankFiled/rankField

要不要来水一个 pr ？

[Reid00]

ok 我稍后提一个，我还真没注意rankdField 拼错了，一直是复制.

[wey]

词序不影响人脑理解

[MJ1]

请问这边方便提供一个pySpark写入边成功的demo吗，我想参考一下

[Reid00]

    df.write.format("com.vesoft.nebula.connector.NebulaDataSource")\
    .mode("overwrite")\
    .option("timeout", 300000)\
    .option("connectionRetry", 1)\
    .option("executionRetry", 2)\
    .option("srcPolicy", "")\
    .option("dstPolicy", "")\
    .option("metaAddress", metaHost[cluster])\
    .option("graphAddress", graphHost[cluster])\
    .option("user", "root")\
    .option("passwd", "nebula")\
    .option("type", "edge")\
    .option("spaceName", "Relation")\
    .option("label", "rel")\
    .option("srcVertexField", "srcid")\
    .option("dstVertexField", "dstid")\
    .option("rankFiled", "")\
    .option("batch", 3000)\
    .option("writeMode", "insert").save()   

我提个pr 加上个py example 吧 @wey

[wey]

麻烦提一个吧！在 readme 上，加上 doc effect，如果可以再去 docs-cn repo 也提一个 ，现在都是只有点写入

[Reid00]

是的，我用的也是这个版本，我的nebula 是v3.2.0 看readme 是都兼容的。
你检查下 你的数据有没有null 值

[Reid00]

你的Dataframe schema 和 edge 的schema 相同吗

[Reid00]

没看出来哪里不对

[MJ1]

不好意思哈，这边犯了低级错误导致的，您这边提供的方法是对的，问题已经解决了，谢谢帮助

[MJ1]

问题已解决，谢谢二位 @wey @Reid00