neo4j-spark-connector
发布于 6 年前 作者 goodwater 2588 次浏览 来自 问答

请教各位大神 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”)

回到顶部