[
https://issues.apache.org/jira/browse/NIFI-8209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17293265#comment-17293265
]
Matt Burgess commented on NIFI-8209:
------------------------------------
The "fix" would break anyone using Neo4J version <3.5 and that's what we
currently support so we couldn't just upgrade the driver. I think instead we
should look at adding a new controller service that uses the latest driver at
the time, your customer would just have to switch over to the new service (and
unless the new service is small in size, they might need to download the NAR
separately from the normal Apache NiFi binary distribution, we have reached our
size limit so we can't add any more big NARs by default, they often have to be
downloaded separately from Apache.
> The Apache Nifi 1.12.1 Neo4JCypherClientService controller service hangs
> indefinitely attempting to connect to Neo4j 4.2.3
> --------------------------------------------------------------------------------------------------------------------------
>
> Key: NIFI-8209
> URL: https://issues.apache.org/jira/browse/NIFI-8209
> Project: Apache NiFi
> Issue Type: Bug
> Components: Extensions, Tools and Build
> Affects Versions: 1.12.1
> Environment: UNIX/CentOS 7
> Reporter: freddie Burgess
> Priority: Major
>
> The latest Neo4j Controller Service in Nifi from the graph bundle has been
> built using neo4j-java-driver v1.6.2 and is not compatible with Neo4j 4.x.
> Enabling the controller fails in reaching the Neo4j database.
> neo4j-enterprise-edition
> Nifi 1.11.x + Neo 4.2.2 => ServiceUnavailableException
> Nifi 1.11.x + Neo 4.1.5 => ServiceUnavailableException
> Nifi 1.11.x + Neo 4.0.11 => ServiceUnavailableException
> Nifi 1.11.x + Neo 3.5.26 => OK
> neo4j-community-edition
> Nifi 1.12.x + Neo 4.2.3 => ServiceUnavailableException
> Nifi 1.12.x + Neo 4.2.2 => ServiceUnavailableException
> Nifi 1.11.x + Neo 4.1.5 => ServiceUnavailableException
> Nifi 1.11.x + Neo 4.0.11 => ServiceUnavailableException
> Nifi 1.11.x + Neo 3.5.26 => OK
>
> 2021-01-13 20:00:02,167 ERROR [Timer-Driven Process Thread-9]
> o.a.n.c.s.StandardControllerServiceNode
> StandardControllerServiceNode[service=Neo4JCypherClientService[id=192a1810-11da-101d-b4cd-f704063cba3d],
> versionedComponentId=null,
> processGroup=StandardProcessGroup[identifier=6038b1ce-016d-1000-68fc-0a8f542cf79b,name=NiFi
> Flow], active=true] Failed to invoke @OnEnabled method due to
> org.apache.nifi.processor.exception.ProcessException: Error while getting
> connectionConnection to the database terminated. This can happen due to
> network instabilities, or due to restarts of the database: {}
> org.apache.nifi.processor.exception.ProcessException: Error while getting
> connectionConnection to the database terminated. This can happen due to
> network instabilities, or due to restarts of the database
> at
> org.apache.nifi.graph.Neo4JCypherClientService.onEnabled(Neo4JCypherClientService.java:255)
> at jdk.internal.reflect.GeneratedMethodAccessor505.invoke(Unknown Source)
> at
> java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> at java.base/java.lang.reflect.Method.invoke(Method.java:566)
> at
> org.apache.nifi.util.ReflectionUtils.invokeMethodsWithAnnotations(ReflectionUtils.java:142)
> at
> org.apache.nifi.util.ReflectionUtils.invokeMethodsWithAnnotations(ReflectionUtils.java:130)
> at
> org.apache.nifi.util.ReflectionUtils.invokeMethodsWithAnnotations(ReflectionUtils.java:75)
> at
> org.apache.nifi.util.ReflectionUtils.invokeMethodsWithAnnotation(ReflectionUtils.java:52)
> at
> org.apache.nifi.controller.service.StandardControllerServiceNode$2.run(StandardControllerServiceNode.java:432)
> at org.apache.nifi.engine.FlowEngine$2.run(FlowEngine.java:110)
> at
> java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
> at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
> at
> java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304)
> at
> java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
> at
> java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
> at java.base/java.lang.Thread.run(Thread.java:834)
> Caused by: org.neo4j.driver.v1.exceptions.ServiceUnavailableException:
> Connection to the database terminated. This can happen due to network
> instabilities, or due to restarts of the database
> at
> org.neo4j.driver.internal.util.ErrorUtil.newConnectionTerminatedError(ErrorUtil.java:45)
> at
> org.neo4j.driver.internal.async.HandshakeHandler.channelInactive(HandshakeHandler.java:85)
> at
> org.neo4j.driver.internal.shaded.io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:245)
> at
> org.neo4j.driver.internal.shaded.io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:231)
> at
> org.neo4j.driver.internal.shaded.io.netty.channel.AbstractChannelHandlerContext.fireChannelInactive(AbstractChannelHandlerContext.java:224)
> at
> org.neo4j.driver.internal.shaded.io.netty.handler.codec.ByteToMessageDecoder.channelInputClosed(ByteToMessageDecoder.java:377)
> at
> org.neo4j.driver.internal.shaded.io.netty.handler.codec.ByteToMessageDecoder.channelInactive(ByteToMessageDecoder.java:342)
> at
> org.neo4j.driver.internal.shaded.io.netty.handler.ssl.SslHandler.channelInactive(SslHandler.java:1010)
> at
> org.neo4j.driver.internal.shaded.io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:245)
> at
> org.neo4j.driver.internal.shaded.io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:231)
> at
> org.neo4j.driver.internal.shaded.io.netty.channel.AbstractChannelHandlerContext.fireChannelInactive(AbstractChannelHandlerContext.java:224)
> at
> org.neo4j.driver.internal.shaded.io.netty.channel.ChannelInboundHandlerAdapter.channelInactive(ChannelInboundHandlerAdapter.java:75)
> at
> org.neo4j.driver.internal.shaded.io.netty.handler.timeout.IdleStateHandler.channelInactive(IdleStateHandler.java:277)
> at
> org.neo4j.driver.internal.shaded.io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:245)
> at
> org.neo4j.driver.internal.shaded.io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:231)
> at
> org.neo4j.driver.internal.shaded.io.netty.channel.AbstractChannelHandlerContext.fireChannelInactive(AbstractChannelHandlerContext.java:224)
> at
> org.neo4j.driver.internal.shaded.io.netty.channel.DefaultChannelPipeline$HeadContext.channelInactive(DefaultChannelPipeline.java:1409)
> at
> org.neo4j.driver.internal.shaded.io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:245)
> at
> org.neo4j.driver.internal.shaded.io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:231)
> at
> org.neo4j.driver.internal.shaded.io.netty.channel.DefaultChannelPipeline.fireChannelInactive(DefaultChannelPipeline.java:927)
> at
> org.neo4j.driver.internal.shaded.io.netty.channel.AbstractChannel$AbstractUnsafe$8.run(AbstractChannel.java:822)
> at
> org.neo4j.driver.internal.shaded.io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:163)
> at
> org.neo4j.driver.internal.shaded.io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404)
> at
> org.neo4j.driver.internal.shaded.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:463)
> 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)
> ... 1 common frames omitted
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
