微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦！

Neo4j Java 驱动程序问题

分类：编程问答

如何解决Neo4j Java 驱动程序问题

我使用的是 Neo4j Java 驱动程序 1.7.5 版本，但无法找到如何从 Java 驱动程序文档/博客传递字符集。

请您分享一下如何通过java驱动程序传递字符集？

实际上，我在使用 Neo4j Java 驱动程序时遇到了一个问题。

我的 spark 作业将创建几个 CSV 并将它们保存到 HDFS 中。使用 Akka HTTP，我流式传输这些文件并运行加载 CSV Cypher 查询。一段时间后，我收到以下错误，但找不到原因。

这里 CSV 被分成多个文件，这些文件总共包含 5300 万条记录。

ava.lang.RuntimeException: Exception while executing te following
neo4j query
USING PERIODIC COMMIT
LOAD CSV WITH HEADERS FROM
"http://cdp-dn27.stg.iad1.ccmteam.com:7111/ingestion-files/part-00000-121ed02d-6ebf-4958-9e8e-bd7b4337bda4-c000.csv"
AS param FIELDTERMINATOR "|"
MATCH (person1:Person {person_guid: param.user1}),(person2:Person
{person_guid: param.user2})
MERGE (person1)-[r:KNowS]-(person2)
      SET r.last_tran_time = CASE WHEN toInteger(param.last_tran_date) >
coalesce(r.last_tran_time,0) THEN toInteger(param.last_tran_date) ELSE
r.last_tran_time END
SET r.first_tran_time = CASE WHEN toInteger(param.first_tran_date) <
coalesce(r.first_tran_time,9999999999) THEN
toInteger(param.first_tran_date) ELSE r.first_tran_time END
SET r.num_transactions = CASE WHEN EXISTS(r.num_transactions) THEN
r.num_transactions + toInteger(param.num_trans) ELSE
toInteger(param.num_trans) END

        at com.test.graphbuilder.dao.Neo4JDao.runQuery(Neo4JDao.scala:46)
        at
com.test.graphbuilder.service.DataUpdateService$$anonfun$2.apply(DataUpdateService.scala:37)
        at
com.test.graphbuilder.service.DataUpdateService$$anonfun$2.apply(DataUpdateService.scala:30)
        at scala.collection.immutable.List.map(List.scala:284)
        at
com.test.graphbuilder.service.DataUpdateService.updateData(DataUpdateService.scala:30)
        at
com.test.graphbuilder.service.GraphRefreshService$$anonfun$8.apply(GraphRefreshService.scala:49)
        at
com.test.graphbuilder.service.GraphRefreshService$$anonfun$8.apply(GraphRefreshService.scala:49)
        at scala.collection.immutable.List.map(List.scala:288)
        at
com.test.graphbuilder.service.GraphRefreshService.refreshGraph(GraphRefreshService.scala:49)
        at com.test.graphbuilder.KafkaTrigger$.main(KafkaTrigger.scala:22)
        at com.test.graphbuilder.KafkaTrigger.main(KafkaTrigger.scala)
        at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
        at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
        at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
        at java.lang.reflect.Method.invoke(Method.java:498)
        at
org.apache.spark.deploy.yarn.ApplicationMaster$$anon$2.run(ApplicationMaster.scala:673)
Caused by: org.neo4j.driver.v1.exceptions.DatabaseException: Error
occured in read-ahead thread
        at org.neo4j.driver.internal.util.Futures.blockingGet(Futures.java:123)
        at
org.neo4j.driver.internal.InternalStatementResult.blockingGet(InternalStatementResult.java:134)
        at
org.neo4j.driver.internal.InternalStatementResult.consume(InternalStatementResult.java:117)
        at
com.test.graphbuilder.dao.Neo4JDao$$anonfun$runQuery$1$$anonfun$apply$2.apply(Neo4JDao.scala:33)
        at
com.test.graphbuilder.dao.Neo4JDao$$anonfun$runQuery$1$$anonfun$apply$2.apply(Neo4JDao.scala:31)
        at
com.test.graphbuilder.util.AutoClosableutil$.autoClose(AutoClosableutil.scala:6)
        at
com.test.graphbuilder.dao.Neo4JDao$$anonfun$runQuery$1.apply(Neo4JDao.scala:31)
        at
com.test.graphbuilder.dao.Neo4JDao$$anonfun$runQuery$1.apply(Neo4JDao.scala:30)
        at
com.test.graphbuilder.util.AutoClosableutil$.autoClose(AutoClosableutil.scala:6)
        at com.test.graphbuilder.dao.Neo4JDao.runQuery(Neo4JDao.scala:30)
        ... 15 more
        Suppressed: org.neo4j.driver.internal.util.ErrorUtil$InternalExceptionCause
                at
org.neo4j.driver.internal.util.ErrorUtil.newNeo4jError(ErrorUtil.java:72)
                at
org.neo4j.driver.internal.async.inbound.InboundMessagedispatcher.handleFailureMessage(InboundMessagedispatcher.java:105)
                at
org.neo4j.driver.internal.messaging.v1.MessageReaderV1.unpackFailureMessage(MessageReaderV1.java:83)
                at
org.neo4j.driver.internal.messaging.v1.MessageReaderV1.read(MessageReaderV1.java:59)
                at
org.neo4j.driver.internal.async.inbound.InboundMessageHandler.channelRead0(InboundMessageHandler.java:83)
                at
org.neo4j.driver.internal.async.inbound.InboundMessageHandler.channelRead0(InboundMessageHandler.java:35)
                at
org.neo4j.driver.internal.shaded.io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105)
                at
org.neo4j.driver.internal.shaded.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
                at
org.neo4j.driver.internal.shaded.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
                at
org.neo4j.driver.internal.shaded.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
                at
org.neo4j.driver.internal.shaded.io.netty.handler.codec.BytetoMessageDecoder.fireChannelRead(BytetoMessageDecoder.java:310)
                at
org.neo4j.driver.internal.shaded.io.netty.handler.codec.BytetoMessageDecoder.channelRead(BytetoMessageDecoder.java:284)
                at
org.neo4j.driver.internal.async.inbound.MessageDecoder.channelRead(MessageDecoder.java:47)
                at
org.neo4j.driver.internal.shaded.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
                at
org.neo4j.driver.internal.shaded.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
                at
org.neo4j.driver.internal.shaded.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
                at
org.neo4j.driver.internal.shaded.io.netty.handler.codec.BytetoMessageDecoder.fireChannelRead(BytetoMessageDecoder.java:310)
                at
org.neo4j.driver.internal.shaded.io.netty.handler.codec.BytetoMessageDecoder.fireChannelRead(BytetoMessageDecoder.java:297)
                at
org.neo4j.driver.internal.shaded.io.netty.handler.codec.BytetoMessageDecoder.callDecode(BytetoMessageDecoder.java:413)
                at
org.neo4j.driver.internal.shaded.io.netty.handler.codec.BytetoMessageDecoder.channelRead(BytetoMessageDecoder.java:265)
                at
org.neo4j.driver.internal.shaded.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
                at
org.neo4j.driver.internal.shaded.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
                at
org.neo4j.driver.internal.shaded.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
                at
org.neo4j.driver.internal.shaded.io.netty.handler.ssl.SslHandler.unwrap(SslHandler.java:1389)
                at
org.neo4j.driver.internal.shaded.io.netty.handler.ssl.SslHandler.decodeJdkCompatible(SslHandler.java:1159)
                at
org.neo4j.driver.internal.shaded.io.netty.handler.ssl.SslHandler.decode(SslHandler.java:1203)
                at
org.neo4j.driver.internal.shaded.io.netty.handler.codec.BytetoMessageDecoder.decodeRemovalReentryProtection(BytetoMessageDecoder.java:489)
                at
org.neo4j.driver.internal.shaded.io.netty.handler.codec.BytetoMessageDecoder.callDecode(BytetoMessageDecoder.java:428)
                at
org.neo4j.driver.internal.shaded.io.netty.handler.codec.BytetoMessageDecoder.channelRead(BytetoMessageDecoder.java:265)
                at
org.neo4j.driver.internal.shaded.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
                at
org.neo4j.driver.internal.shaded.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
                at
org.neo4j.driver.internal.shaded.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
                at
org.neo4j.driver.internal.shaded.io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1414)
                at
org.neo4j.driver.internal.shaded.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
                at
org.neo4j.driver.internal.shaded.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
                at
org.neo4j.driver.internal.shaded.io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:945)
                at
org.neo4j.driver.internal.shaded.io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:146)
                at
org.neo4j.driver.internal.shaded.io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:645)
                at
org.neo4j.driver.internal.shaded.io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:580)
                at
org.neo4j.driver.internal.shaded.io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:497)
                at
org.neo4j.driver.internal.shaded.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:459)
                at
org.neo4j.driver.internal.shaded.io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:886)
                at
org.neo4j.driver.internal.shaded.io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
                at java.lang.Thread.run(Thread.java:748)

提前致谢。请帮我解决这个问题

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。

苹果市值2025年有望达4万亿美元
pythonJavaScriptjavaHTMLPHPreactjsC#AndroidCSSNode.jssqlrpython-3.xMysqLjQueryc++pandasFlutterangularIOSdjangolinuxswifttypescript路由器JSON路由器设置无线路由器h3c华三华三路由器设置华三路由器电脑软件教程arraysdocker软件图文教程Cvue.jslaravelspring-boot