SparkConnector中没有定义createDataReaderFactories方法,你使用的Spark是什么版本的, 我们要求必须是2.3 以上版本。
我是参考的https://github.com/vesoft-inc/nebula-spark-utils的example,master和v2.0.0分支的代码都试了,同样的错误,spark版本2.4.4。
我这边执行去执行Exchange的reader可以读到数据
你用StorageClient读没问题,应该是你的Spark相关的jar存在包冲突,你看下执行程序的机器上是否有2.2版本的Spark,你的Spark-connector包是怎么来的,是在远程maven库下载的还是最新的master编译的?
我怀疑你的环境中使用的包有问题,你清理下环境。 wget下载maven上的jar包:
wget https://repo1.maven.org/maven2/com/vesoft/nebula-spark-connector/2.0.0/nebula-spark-connector-2.0.0.jar
1 个赞
Spark-connector包是最新的master编译的。
这个问题我遇见过 是spark版本的问题
1 个赞
哦,你用的哪个版本啊?
2.4.3
大于2.2小于3