nebula-up
nebula-up copied to clipboard
wey-gu
nebula-up/spark /pagerank_example.ipynb，wrong？
when df = spark.read.format( "com.vesoft.nebula.connector.NebulaDataSource").option( "type", "edge").option( "spaceName", "basketballplayer").option( "label", "follow").option( "returnCols", "degree").option( "metaAddress", "metad0:9559").option( "graphAddress", "graphd:9669").option( "ngql", "MATCH ()-[e:follow]->() return e LIMIT 1000").option( "partitionNumber", 1).load()
Py4JJavaError Traceback (most recent call last)
/tmp/ipykernel_652/960065089.py in
/spark/python/pyspark/sql/readwriter.py in load(self, path, format, schema, **options) 170 return self._df(self._jreader.load(self._spark._sc._jvm.PythonUtils.toSeq(path))) 171 else: --> 172 return self._df(self._jreader.load()) 173 174 @since(1.4)
/spark/python/lib/py4j-0.10.7-src.zip/py4j/java_gateway.py in call(self, *args) 1255 answer = self.gateway_client.send_command(command) 1256 return_value = get_return_value( -> 1257 answer, self.gateway_client, self.target_id, self.name) 1258 1259 for temp_arg in temp_args:
/spark/python/pyspark/sql/utils.py in deco(*a, **kw) 61 def deco(*a, **kw): 62 try: ---> 63 return f(*a, **kw) 64 except py4j.protocol.Py4JJavaError as e: 65 s = e.java_exception.toString()
/spark/python/lib/py4j-0.10.7-src.zip/py4j/protocol.py in get_return_value(answer, gateway_client, target_id, name) 326 raise Py4JJavaError( 327 "An error occurred while calling {0}{1}{2}.\n". --> 328 format(target_id, ".", name), value) 329 else: 330 raise Py4JError(
Py4JJavaError: An error occurred while calling o57.load.
: java.util.NoSuchElementException: key not found: operateType
at scala.collection.MapLike$class.default(MapLike.scala:228)
at org.apache.spark.sql.catalyst.util.CaseInsensitiveMap.default(CaseInsensitiveMap.scala:28)
at scala.collection.MapLike$class.apply(MapLike.scala:141)
at org.apache.spark.sql.catalyst.util.CaseInsensitiveMap.apply(CaseInsensitiveMap.scala:28)
at com.vesoft.nebula.connector.NebulaOptions.
