neo4j-spark-connector
请教各位大神
spark连接neo4j时报错
ERROR session:42 - Neo4j Session object leaked, please ensure that your application calls the close
method on Sessions before disposing of the objects.
Exception in thread “main” org.neo4j.driver.v1.exceptions.ClientException: Unable to process request: AsynchronousCloseException buffer:
代码:
val conf = new SparkConf().setAppName(“TEST”).setMaster(“local[*]”)
conf.set(“spark.neo4j.bolt.url”,“bolt://localhost:7687”)
conf.set(“spark.neo4j.bolt.user”,“neo4j”)
conf.set(“spark.neo4j.bolt.password”,“123456”)
val sc = new SparkContext(conf)
val g =Neo4jGraph.loadGraph(sc,label1 =“item”,relTypes =Seq(“rel”),label2 = “item”)