search

neo4j / apoc

Apache License 2.0
94 stars 28 forks source link

Trigger generating org.neo4j.graphdb.NotInTransactionException: This transaction has already been closed #411

Open dimitriwoei opened 1 year ago

dimitriwoei commented 1 year ago

Hi,

I'm getting the following error:

Error executing trigger myTrigger in phase afterAsync org.neo4j.graphdb.QueryExecutionException: Failed to invoke function apoc.convert.toJson: Caused by: org.neo4j.graphdb.NotInTransactionException: This transaction has already been closed

The code for the trigger is:

"CALL apoc.load.jsonParams( "http://localhost:8082/topics/neodb-cdc", { method: "POST", Content-Type: "application/vnd.kafka.json.v2+json", Accept: "application/vnd.kafka.v2+json" }, apoc.convert.toJson({records:[{key: "neo4j_update", value: { createdNodes: $createdNodes, deletedNodes: $deletedNodes, createdRelationships: $createdRelationships, deletedRelationships: $deletedRelationships, removedLabels: $removedLabels, removedNodeProperties: $removedNodeProperties, removedRelationshipProperties: $removedRelationshipProperties, assignedLabels: $assignedLabels, assignedNodeProperties: $assignedNodeProperties, assignedRelationshipProperties: $assignedRelationshipProperties } }]}) ) YIELD value RETURN value"

Sometimes the trigger runs without generating errors (I can see that the call to localhost:8082 has been succesful), sometimes it doesn't. It seems quite random.

Expected Behavior (Mandatory)

Execution of the trigger without error

Actual Behavior (Mandatory)

2023-05-16 13:12:42.166+0000 WARN [a.t.TriggerHandler] [neo4j/a139b05b] Error executing trigger myTrigger in phase afterAsync org.neo4j.graphdb.QueryExecutionException: Failed to invoke function apoc.convert.toJson: Caused by: org.neo4j.graphdb.NotInTransactionException: The transaction has been closed. at org.neo4j.kernel.impl.query.QueryExecutionKernelException.asUserException(QueryExecutionKernelException.java:35) ~[neo4j-kernel-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.javacompat.ResultSubscriber.converted(ResultSubscriber.java:426) ~[neo4j-cypher-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.javacompat.ResultSubscriber.assertNoErrors(ResultSubscriber.java:407) ~[neo4j-cypher-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.javacompat.ResultSubscriber.fetchResults(ResultSubscriber.java:363) ~[neo4j-cypher-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.javacompat.ResultSubscriber.nextFromSubscriber(ResultSubscriber.java:330) ~[neo4j-cypher-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.javacompat.ResultSubscriber.fetchNextOrNull(ResultSubscriber.java:301) ~[neo4j-cypher-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.javacompat.ResultSubscriber.fetchNextOrNull(ResultSubscriber.java:58) ~[neo4j-cypher-4.4.8.jar:4.4.8] at org.neo4j.internal.helpers.collection.PrefetchingIterator.peek(PrefetchingIterator.java:60) ~[neo4j-collections-4.4.8.jar:4.4.8] at org.neo4j.internal.helpers.collection.PrefetchingIterator.hasNext(PrefetchingIterator.java:46) ~[neo4j-collections-4.4.8.jar:4.4.8] at org.neo4j.internal.helpers.collection.Iterators.count(Iterators.java:383) ~[neo4j-collections-4.4.8.jar:4.4.8] at org.neo4j.internal.helpers.collection.Iterators.count(Iterators.java:369) ~[neo4j-collections-4.4.8.jar:4.4.8] at apoc.trigger.TriggerHandler.lambda$executeTriggers$14(TriggerHandler.java:267) ~[apoc-4.4.0.8.jar:4.4.0.8] at java.util.concurrent.ConcurrentHashMap.forEach(ConcurrentHashMap.java:1603) ~[?:?] at apoc.trigger.TriggerHandler.executeTriggers(TriggerHandler.java:257) ~[apoc-4.4.0.8.jar:4.4.0.8] at apoc.trigger.TriggerHandler.lambda$afterAsync$11(TriggerHandler.java:229) ~[apoc-4.4.0.8.jar:4.4.0.8] at apoc.util.Util.retryInTx(Util.java:217) ~[apoc-4.4.0.8.jar:4.4.0.8] at apoc.util.Util.lambda$inTxFuture$4(Util.java:241) ~[apoc-4.4.0.8.jar:4.4.0.8] at java.util.concurrent.FutureTask.run(FutureTask.java:264) [?:?] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) [?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) [?:?] at java.lang.Thread.run(Thread.java:829) [?:?] Caused by: org.neo4j.kernel.impl.query.QueryExecutionKernelException: Failed to invoke function apoc.convert.toJson: Caused by: org.neo4j.graphdb.NotInTransactionException: The transaction has been closed. ... 20 more Caused by: org.neo4j.exceptions.CypherExecutionException: Failed to invoke function apoc.convert.toJson: Caused by: org.neo4j.graphdb.NotInTransactionException: The transaction has been closed. at org.neo4j.cypher.internal.planning.ExceptionTranslatingReadQueryContext.callFunction(ExceptionTranslatingQueryContext.scala:237) ~[neo4j-cypher-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.interpreted.commands.expressions.UserFunctionInvocation.call(FunctionInvocation.scala:58) ~[neo4j-cypher-interpreted-runtime-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.interpreted.commands.expressions.FunctionInvocation.apply(FunctionInvocation.scala:42) ~[neo4j-cypher-interpreted-runtime-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.interpreted.commands.expressions.CoerceTo.apply(CoerceTo.scala:31) ~[neo4j-cypher-interpreted-runtime-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.interpreted.pipes.ProcedureCallPipe.$anonfun$internalCreateResultsByAppending$2(ProcedureCallPipe.scala:73) ~[neo4j-cypher-interpreted-runtime-4.4.8.jar:4.4.8] at scala.collection.immutable.List.map(List.scala:297) ~[scala-library-2.12.13.jar:?] at org.neo4j.cypher.internal.runtime.interpreted.pipes.ProcedureCallPipe.$anonfun$internalCreateResultsByAppending$1(ProcedureCallPipe.scala:73) ~[neo4j-cypher-interpreted-runtime-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.ClosingIterator$$anon$1.nextCur(ClosingIterator.scala:107) ~[neo4j-cypher-runtime-util-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.ClosingIterator$$anon$1.innerHasNext(ClosingIterator.scala:113) ~[neo4j-cypher-runtime-util-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.ClosingIterator.hasNext(ClosingIterator.scala:93) ~[neo4j-cypher-runtime-util-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.ClosingIterator$$anon$3.innerHasNext(ClosingIterator.scala:152) ~[neo4j-cypher-runtime-util-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.ClosingIterator.hasNext(ClosingIterator.scala:93) ~[neo4j-cypher-runtime-util-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.interpreted.PipeExecutionResult.serveResults(PipeExecutionResult.scala:85) ~[neo4j-cypher-interpreted-runtime-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.interpreted.PipeExecutionResult.request(PipeExecutionResult.scala:73) ~[neo4j-cypher-interpreted-runtime-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.result.StandardInternalExecutionResult.request(StandardInternalExecutionResult.scala:90) ~[neo4j-cypher-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.result.ClosingExecutionResult.request(ClosingExecutionResult.scala:144) ~[neo4j-cypher-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.javacompat.ResultSubscriber.fetchResults(ResultSubscriber.java:362) ~[neo4j-cypher-4.4.8.jar:4.4.8] ... 17 more Caused by: org.neo4j.internal.kernel.api.exceptions.ProcedureException: Failed to invoke function apoc.convert.toJson: Caused by: org.neo4j.graphdb.NotInTransactionException: The transaction has been closed. at org.neo4j.procedure.impl.ProcedureCompilation.rethrowProcedureException(ProcedureCompilation.java:534) ~[neo4j-procedure-4.4.8.jar:4.4.8] at org.neo4j.kernel.impl.proc.GeneratedFunction_toJson3893895974330232.apply(Unknown Source) ~[?:?] at org.neo4j.procedure.impl.ProcedureRegistry.callFunction(ProcedureRegistry.java:250) ~[neo4j-procedure-4.4.8.jar:4.4.8] at org.neo4j.procedure.impl.GlobalProceduresRegistry.callFunction(GlobalProceduresRegistry.java:358) ~[neo4j-procedure-4.4.8.jar:4.4.8] at org.neo4j.kernel.impl.newapi.AllStoreHolder.callFunction(AllStoreHolder.java:1139) ~[neo4j-kernel-4.4.8.jar:4.4.8] at org.neo4j.kernel.impl.newapi.AllStoreHolder.functionCall(AllStoreHolder.java:1031) ~[neo4j-kernel-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.interpreted.CallSupport$.callFunction(CallSupport.scala:38) ~[neo4j-cypher-interpreted-runtime-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.interpreted.TransactionBoundReadQueryContext.callFunction(TransactionBoundQueryContext.scala:1150) ~[neo4j-cypher-interpreted-runtime-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.planning.ExceptionTranslatingReadQueryContext.callFunction(ExceptionTranslatingQueryContext.scala:237) ~[neo4j-cypher-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.interpreted.commands.expressions.UserFunctionInvocation.call(FunctionInvocation.scala:58) ~[neo4j-cypher-interpreted-runtime-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.interpreted.commands.expressions.FunctionInvocation.apply(FunctionInvocation.scala:42) ~[neo4j-cypher-interpreted-runtime-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.interpreted.commands.expressions.CoerceTo.apply(CoerceTo.scala:31) ~[neo4j-cypher-interpreted-runtime-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.interpreted.pipes.ProcedureCallPipe.$anonfun$internalCreateResultsByAppending$2(ProcedureCallPipe.scala:73) ~[neo4j-cypher-interpreted-runtime-4.4.8.jar:4.4.8] at scala.collection.immutable.List.map(List.scala:297) ~[scala-library-2.12.13.jar:?] at org.neo4j.cypher.internal.runtime.interpreted.pipes.ProcedureCallPipe.$anonfun$internalCreateResultsByAppending$1(ProcedureCallPipe.scala:73) ~[neo4j-cypher-interpreted-runtime-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.ClosingIterator$$anon$1.nextCur(ClosingIterator.scala:107) ~[neo4j-cypher-runtime-util-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.ClosingIterator$$anon$1.innerHasNext(ClosingIterator.scala:113) ~[neo4j-cypher-runtime-util-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.ClosingIterator.hasNext(ClosingIterator.scala:93) ~[neo4j-cypher-runtime-util-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.ClosingIterator$$anon$3.innerHasNext(ClosingIterator.scala:152) ~[neo4j-cypher-runtime-util-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.ClosingIterator.hasNext(ClosingIterator.scala:93) ~[neo4j-cypher-runtime-util-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.interpreted.PipeExecutionResult.serveResults(PipeExecutionResult.scala:85) ~[neo4j-cypher-interpreted-runtime-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.interpreted.PipeExecutionResult.request(PipeExecutionResult.scala:73) ~[neo4j-cypher-interpreted-runtime-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.result.StandardInternalExecutionResult.request(StandardInternalExecutionResult.scala:90) ~[neo4j-cypher-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.result.ClosingExecutionResult.request(ClosingExecutionResult.scala:144) ~[neo4j-cypher-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.javacompat.ResultSubscriber.fetchResults(ResultSubscriber.java:362) ~[neo4j-cypher-4.4.8.jar:4.4.8] ... 17 more Caused by: org.neo4j.graphdb.NotInTransactionException: The transaction has been closed. at org.neo4j.kernel.impl.coreapi.TransactionImpl.checkInTransaction(TransactionImpl.java:879) ~[neo4j-kernel-4.4.8.jar:4.4.8] at org.neo4j.kernel.impl.coreapi.TransactionImpl.kernelTransaction(TransactionImpl.java:740) ~[neo4j-kernel-4.4.8.jar:4.4.8] at org.neo4j.kernel.impl.core.NodeEntity.getLabels(NodeEntity.java:611) ~[neo4j-kernel-4.4.8.jar:4.4.8] at apoc.convert.Json.nodeToMap(Json.java:68) ~[apoc-4.4.0.8.jar:4.4.0.8] at apoc.convert.Json.relToMap(Json.java:57) ~[apoc-4.4.0.8.jar:4.4.0.8] at apoc.convert.Json.writeJsonResult(Json.java:34) ~[apoc-4.4.0.8.jar:4.4.0.8] at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195) ~[?:?] at java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1655) ~[?:?] at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:484) ~[?:?] at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474) ~[?:?] at java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:913) ~[?:?] at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) ~[?:?] at java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:578) ~[?:?] at apoc.convert.Json.writeJsonResult(Json.java:40) ~[apoc-4.4.0.8.jar:4.4.0.8] at apoc.convert.Json.lambda$writeJsonResult$1(Json.java:45) ~[apoc-4.4.0.8.jar:4.4.0.8] at java.util.stream.ReduceOps$4ReducingSink.accept(ReduceOps.java:220) ~[?:?] at java.util.HashMap$EntrySpliterator.forEachRemaining(HashMap.java:1764) ~[?:?] at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:484) ~[?:?] at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474) ~[?:?] at java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:913) ~[?:?] at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) ~[?:?] at java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:589) ~[?:?] at apoc.convert.Json.writeJsonResult(Json.java:44) ~[apoc-4.4.0.8.jar:4.4.0.8] at apoc.convert.Json.lambda$writeJsonResult$1(Json.java:45) ~[apoc-4.4.0.8.jar:4.4.0.8] at java.util.stream.ReduceOps$4ReducingSink.accept(ReduceOps.java:220) ~[?:?] at java.util.HashMap$EntrySpliterator.forEachRemaining(HashMap.java:1764) ~[?:?] at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:484) ~[?:?] at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474) ~[?:?] at java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:913) ~[?:?] at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) ~[?:?] at java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:589) ~[?:?] at apoc.convert.Json.writeJsonResult(Json.java:44) ~[apoc-4.4.0.8.jar:4.4.0.8] at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195) ~[?:?] at java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1655) ~[?:?] at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:484) ~[?:?] at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474) ~[?:?] at java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:913) ~[?:?] at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) ~[?:?] at java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:578) ~[?:?] at apoc.convert.Json.writeJsonResult(Json.java:40) ~[apoc-4.4.0.8.jar:4.4.0.8] at apoc.convert.Json.lambda$writeJsonResult$1(Json.java:45) ~[apoc-4.4.0.8.jar:4.4.0.8] at java.util.stream.ReduceOps$4ReducingSink.accept(ReduceOps.java:220) ~[?:?] at java.util.HashMap$EntrySpliterator.forEachRemaining(HashMap.java:1764) ~[?:?] at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:484) ~[?:?] at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474) ~[?:?] at java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:913) ~[?:?] at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) ~[?:?] at java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:589) ~[?:?] at apoc.convert.Json.writeJsonResult(Json.java:44) ~[apoc-4.4.0.8.jar:4.4.0.8] at apoc.convert.Json.toJson(Json.java:93) ~[apoc-4.4.0.8.jar:4.4.0.8] at org.neo4j.kernel.impl.proc.GeneratedFunction_toJson3893895974330232.apply(Unknown Source) ~[?:?] at org.neo4j.procedure.impl.ProcedureRegistry.callFunction(ProcedureRegistry.java:250) ~[neo4j-procedure-4.4.8.jar:4.4.8] at org.neo4j.procedure.impl.GlobalProceduresRegistry.callFunction(GlobalProceduresRegistry.java:358) ~[neo4j-procedure-4.4.8.jar:4.4.8] at org.neo4j.kernel.impl.newapi.AllStoreHolder.callFunction(AllStoreHolder.java:1139) ~[neo4j-kernel-4.4.8.jar:4.4.8] at org.neo4j.kernel.impl.newapi.AllStoreHolder.functionCall(AllStoreHolder.java:1031) ~[neo4j-kernel-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.interpreted.CallSupport$.callFunction(CallSupport.scala:38) ~[neo4j-cypher-interpreted-runtime-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.interpreted.TransactionBoundReadQueryContext.callFunction(TransactionBoundQueryContext.scala:1150) ~[neo4j-cypher-interpreted-runtime-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.planning.ExceptionTranslatingReadQueryContext.callFunction(ExceptionTranslatingQueryContext.scala:237) ~[neo4j-cypher-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.interpreted.commands.expressions.UserFunctionInvocation.call(FunctionInvocation.scala:58) ~[neo4j-cypher-interpreted-runtime-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.interpreted.commands.expressions.FunctionInvocation.apply(FunctionInvocation.scala:42) ~[neo4j-cypher-interpreted-runtime-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.interpreted.commands.expressions.CoerceTo.apply(CoerceTo.scala:31) ~[neo4j-cypher-interpreted-runtime-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.interpreted.pipes.ProcedureCallPipe.$anonfun$internalCreateResultsByAppending$2(ProcedureCallPipe.scala:73) ~[neo4j-cypher-interpreted-runtime-4.4.8.jar:4.4.8] at scala.collection.immutable.List.map(List.scala:297) ~[scala-library-2.12.13.jar:?] at org.neo4j.cypher.internal.runtime.interpreted.pipes.ProcedureCallPipe.$anonfun$internalCreateResultsByAppending$1(ProcedureCallPipe.scala:73) ~[neo4j-cypher-interpreted-runtime-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.ClosingIterator$$anon$1.nextCur(ClosingIterator.scala:107) ~[neo4j-cypher-runtime-util-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.ClosingIterator$$anon$1.innerHasNext(ClosingIterator.scala:113) ~[neo4j-cypher-runtime-util-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.ClosingIterator.hasNext(ClosingIterator.scala:93) ~[neo4j-cypher-runtime-util-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.ClosingIterator$$anon$3.innerHasNext(ClosingIterator.scala:152) ~[neo4j-cypher-runtime-util-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.ClosingIterator.hasNext(ClosingIterator.scala:93) ~[neo4j-cypher-runtime-util-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.interpreted.PipeExecutionResult.serveResults(PipeExecutionResult.scala:85) ~[neo4j-cypher-interpreted-runtime-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.interpreted.PipeExecutionResult.request(PipeExecutionResult.scala:73) ~[neo4j-cypher-interpreted-runtime-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.result.StandardInternalExecutionResult.request(StandardInternalExecutionResult.scala:90) ~[neo4j-cypher-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.result.ClosingExecutionResult.request(ClosingExecutionResult.scala:144) ~[neo4j-cypher-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.javacompat.ResultSubscriber.fetchResults(ResultSubscriber.java:362) ~[neo4j-cypher-4.4.8.jar:4.4.8] ... 17 more

How to Reproduce the Problem

use apoc.refactor.cloneNodes or apoc.refactor.cloneSubGraph including relationships of a medium sized graph.

Specifications (Mandatory)

Currently used versions

Versions

Neo4j Docker image: neo4j:4.4.8-community APOC version: 4.4.0.8

Lojjs commented 1 year ago

@dimitriwoei Thanks for reporting! We will investigate and come back to you

Best regards Louise, Neo4j Cypher Surface team

dimitriwoei commented 1 year ago

Hi,

I'm getting this error more consistently when removing relationships. Hope this helps.

dimitriwoei commented 1 year ago

I tried using phase: before for $deletedRelationships, and $deletedNodes:

CALL apoc.trigger.add('setLastDelete', 'CALL apoc.load.jsonParams( "http://localhost:8082/topics/neodb-cdc", { method: "POST", Content-Type: "application/vnd.kafka.json.v2+json", Accept: "application/vnd.kafka.v2+json" }, apoc.convert.toJson({records:[{key: "neo4j_update", value: { deletedRelationships: $deletedRelationships, deletedNodes: $deletedNodes } }]}) ) YIELD value RETURN value', {phase:'before'});

but when removing a node I get the following error:

2023-05-30 14:20:37.416+0000 WARN [neo4j/a139b05b] Error executing trigger setLastDelete in phase before org.neo4j.graphdb.QueryExecutionException: Failed to invoke function apoc.convert.toJson: Caused by: org.neo4j.internal.kernel.api.exceptions.EntityNotFoundException: Unable to load NODE with id 7448. at org.neo4j.kernel.impl.query.QueryExecutionKernelException.asUserException(QueryExecutionKernelException.java:35) ~[neo4j-kernel-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.javacompat.ResultSubscriber.converted(ResultSubscriber.java:426) ~[neo4j-cypher-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.javacompat.ResultSubscriber.assertNoErrors(ResultSubscriber.java:407) ~[neo4j-cypher-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.javacompat.ResultSubscriber.fetchResults(ResultSubscriber.java:363) ~[neo4j-cypher-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.javacompat.ResultSubscriber.nextFromSubscriber(ResultSubscriber.java:330) ~[neo4j-cypher-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.javacompat.ResultSubscriber.fetchNextOrNull(ResultSubscriber.java:301) ~[neo4j-cypher-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.javacompat.ResultSubscriber.fetchNextOrNull(ResultSubscriber.java:58) ~[neo4j-cypher-4.4.8.jar:4.4.8] at org.neo4j.internal.helpers.collection.PrefetchingIterator.peek(PrefetchingIterator.java:60) ~[neo4j-collections-4.4.8.jar:4.4.8] at org.neo4j.internal.helpers.collection.PrefetchingIterator.hasNext(PrefetchingIterator.java:46) ~[neo4j-collections-4.4.8.jar:4.4.8] at org.neo4j.internal.helpers.collection.Iterators.count(Iterators.java:383) ~[neo4j-collections-4.4.8.jar:4.4.8] at org.neo4j.internal.helpers.collection.Iterators.count(Iterators.java:369) ~[neo4j-collections-4.4.8.jar:4.4.8] at apoc.trigger.TriggerHandler.lambda$executeTriggers$14(TriggerHandler.java:267) ~[apoc-4.4.0.8.jar:4.4.0.8] at java.util.concurrent.ConcurrentHashMap.forEach(ConcurrentHashMap.java:1603) ~[?:?] at apoc.trigger.TriggerHandler.executeTriggers(TriggerHandler.java:257) ~[apoc-4.4.0.8.jar:4.4.0.8] at apoc.trigger.TriggerHandler.executeTriggers(TriggerHandler.java:252) ~[apoc-4.4.0.8.jar:4.4.0.8] at apoc.trigger.TriggerHandler.beforeCommit(TriggerHandler.java:209) ~[apoc-4.4.0.8.jar:4.4.0.8] at apoc.trigger.TriggerHandler.beforeCommit(TriggerHandler.java:40) ~[apoc-4.4.0.8.jar:4.4.0.8] at org.neo4j.kernel.internal.event.DatabaseTransactionEventListeners.beforeCommit(DatabaseTransactionEventListeners.java:101) ~[neo4j-kernel-4.4.8.jar:4.4.8] at org.neo4j.kernel.impl.api.KernelTransactionImplementation.commitTransaction(KernelTransactionImplementation.java:826) ~[neo4j-kernel-4.4.8.jar:4.4.8] at org.neo4j.kernel.impl.api.KernelTransactionImplementation.closeTransaction(KernelTransactionImplementation.java:736) ~[neo4j-kernel-4.4.8.jar:4.4.8] at org.neo4j.kernel.impl.api.KernelTransactionImplementation.commit(KernelTransactionImplementation.java:707) ~[neo4j-kernel-4.4.8.jar:4.4.8] at org.neo4j.kernel.impl.coreapi.TransactionImpl.lambda$commit$0(TransactionImpl.java:179) ~[neo4j-kernel-4.4.8.jar:4.4.8] at org.neo4j.kernel.impl.coreapi.TransactionImpl.safeTerminalOperation(TransactionImpl.java:700) ~[neo4j-kernel-4.4.8.jar:4.4.8] at org.neo4j.kernel.impl.coreapi.TransactionImpl.commit(TransactionImpl.java:174) ~[neo4j-kernel-4.4.8.jar:4.4.8] at org.neo4j.kernel.impl.coreapi.TransactionImpl.commit(TransactionImpl.java:169) ~[neo4j-kernel-4.4.8.jar:4.4.8] at org.neo4j.fabric.executor.FabricKernelTransaction.commit(FabricKernelTransaction.java:137) ~[neo4j-fabric-4.4.8.jar:4.4.8] at org.neo4j.fabric.executor.FabricLocalExecutor$KernelTxWrapper.doCommit(FabricLocalExecutor.java:269) ~[neo4j-fabric-4.4.8.jar:4.4.8] at reactor.core.publisher.MonoRunnable.call(MonoRunnable.java:73) ~[reactor-core-3.4.15.jar:3.4.15] at reactor.core.publisher.MonoRunnable.call(MonoRunnable.java:32) ~[reactor-core-3.4.15.jar:3.4.15] at reactor.core.publisher.FluxFlatMap.trySubscribeScalarMap(FluxFlatMap.java:127) ~[reactor-core-3.4.15.jar:3.4.15] at reactor.core.publisher.MonoFlatMap.subscribeOrReturn(MonoFlatMap.java:53) ~[reactor-core-3.4.15.jar:3.4.15] at reactor.core.publisher.Mono.subscribe(Mono.java:4385) ~[reactor-core-3.4.15.jar:3.4.15] at reactor.core.publisher.FluxFlatMap$FlatMapMain.onNext(FluxFlatMap.java:426) ~[reactor-core-3.4.15.jar:3.4.15] at reactor.core.publisher.FluxConcatArray$ConcatArraySubscriber.onNext(FluxConcatArray.java:201) ~[reactor-core-3.4.15.jar:3.4.15] at reactor.core.publisher.Operators$ScalarSubscription.request(Operators.java:2398) ~[reactor-core-3.4.15.jar:3.4.15] at reactor.core.publisher.FluxConcatArray$ConcatArraySubscriber.onSubscribe(FluxConcatArray.java:193) ~[reactor-core-3.4.15.jar:3.4.15] at reactor.core.publisher.MonoJust.subscribe(MonoJust.java:55) ~[reactor-core-3.4.15.jar:3.4.15] at reactor.core.publisher.Mono.subscribe(Mono.java:4400) ~[reactor-core-3.4.15.jar:3.4.15] at reactor.core.publisher.FluxConcatArray$ConcatArraySubscriber.onComplete(FluxConcatArray.java:258) ~[reactor-core-3.4.15.jar:3.4.15] at reactor.core.publisher.FluxConcatArray.subscribe(FluxConcatArray.java:78) ~[reactor-core-3.4.15.jar:3.4.15] at reactor.core.publisher.Mono.subscribe(Mono.java:4400) ~[reactor-core-3.4.15.jar:3.4.15] at reactor.core.publisher.Mono.block(Mono.java:1706) ~[reactor-core-3.4.15.jar:3.4.15] at org.neo4j.fabric.transaction.FabricTransactionImpl.doOnChildren(FabricTransactionImpl.java:296) ~[neo4j-fabric-4.4.8.jar:4.4.8] at org.neo4j.fabric.transaction.FabricTransactionImpl.commit(FabricTransactionImpl.java:207) ~[neo4j-fabric-4.4.8.jar:4.4.8] at org.neo4j.fabric.bolt.BoltFabricDatabaseService$BoltTransactionImpl.commit(BoltFabricDatabaseService.java:146) ~[neo4j-fabric-4.4.8.jar:4.4.8] at org.neo4j.bolt.runtime.statemachine.impl.TransactionStateMachine$State.closeTransaction(TransactionStateMachine.java:406) ~[neo4j-bolt-4.4.8.jar:4.4.8] at org.neo4j.bolt.runtime.statemachine.impl.TransactionStateMachine$State$2.commitTransaction(TransactionStateMachine.java:358) ~[neo4j-bolt-4.4.8.jar:4.4.8] at org.neo4j.bolt.runtime.statemachine.impl.TransactionStateMachine.commitTransaction(TransactionStateMachine.java:108) ~[neo4j-bolt-4.4.8.jar:4.4.8] at org.neo4j.bolt.transaction.StatementProcessorTxManager.commit(StatementProcessorTxManager.java:66) ~[neo4j-bolt-4.4.8.jar:4.4.8] at org.neo4j.bolt.v4.runtime.InTransactionState.processCommitMessage(InTransactionState.java:107) ~[neo4j-bolt-4.4.8.jar:4.4.8] at org.neo4j.bolt.v44.runtime.InTransactionState.processCommitMessage(InTransactionState.java:35) ~[neo4j-bolt-4.4.8.jar:4.4.8] at org.neo4j.bolt.v4.runtime.InTransactionState.processUnsafe(InTransactionState.java:56) ~[neo4j-bolt-4.4.8.jar:4.4.8] at org.neo4j.bolt.v3.runtime.FailSafeBoltStateMachineState.process(FailSafeBoltStateMachineState.java:48) ~[neo4j-bolt-4.4.8.jar:4.4.8] at org.neo4j.bolt.runtime.statemachine.impl.AbstractBoltStateMachine.nextState(AbstractBoltStateMachine.java:154) ~[neo4j-bolt-4.4.8.jar:4.4.8] at org.neo4j.bolt.runtime.statemachine.impl.AbstractBoltStateMachine.process(AbstractBoltStateMachine.java:102) ~[neo4j-bolt-4.4.8.jar:4.4.8] at org.neo4j.bolt.messaging.BoltRequestMessageReader.lambda$doRead$1(BoltRequestMessageReader.java:93) ~[neo4j-bolt-4.4.8.jar:4.4.8] at org.neo4j.bolt.runtime.DefaultBoltConnection.lambda$enqueue$0(DefaultBoltConnection.java:156) ~[neo4j-bolt-4.4.8.jar:4.4.8] at org.neo4j.bolt.runtime.DefaultBoltConnection.processNextBatchInternal(DefaultBoltConnection.java:252) ~[neo4j-bolt-4.4.8.jar:4.4.8] at org.neo4j.bolt.runtime.DefaultBoltConnection.processNextBatch(DefaultBoltConnection.java:187) ~[neo4j-bolt-4.4.8.jar:4.4.8] at org.neo4j.bolt.runtime.DefaultBoltConnection.processNextBatch(DefaultBoltConnection.java:177) ~[neo4j-bolt-4.4.8.jar:4.4.8] at org.neo4j.bolt.runtime.scheduling.ExecutorBoltScheduler.executeBatch(ExecutorBoltScheduler.java:257) ~[neo4j-bolt-4.4.8.jar:4.4.8] at org.neo4j.bolt.runtime.scheduling.ExecutorBoltScheduler.lambda$scheduleBatchOrHandleError$3(ExecutorBoltScheduler.java:240) ~[neo4j-bolt-4.4.8.jar:4.4.8] at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1700) [?:?] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) [?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) [?:?] at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) [netty-common-4.1.75.Final.jar:4.1.75.Final] at java.lang.Thread.run(Thread.java:829) [?:?] Caused by: org.neo4j.kernel.impl.query.QueryExecutionKernelException: Failed to invoke function apoc.convert.toJson: Caused by: org.neo4j.internal.kernel.api.exceptions.EntityNotFoundException: Unable to load NODE with id 7448. ... 66 more Caused by: org.neo4j.exceptions.CypherExecutionException: Failed to invoke function apoc.convert.toJson: Caused by: org.neo4j.internal.kernel.api.exceptions.EntityNotFoundException: Unable to load NODE with id 7448. at org.neo4j.cypher.internal.planning.ExceptionTranslatingReadQueryContext.callFunction(ExceptionTranslatingQueryContext.scala:237) ~[neo4j-cypher-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.interpreted.commands.expressions.UserFunctionInvocation.call(FunctionInvocation.scala:58) ~[neo4j-cypher-interpreted-runtime-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.interpreted.commands.expressions.FunctionInvocation.apply(FunctionInvocation.scala:42) ~[neo4j-cypher-interpreted-runtime-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.interpreted.commands.expressions.CoerceTo.apply(CoerceTo.scala:31) ~[neo4j-cypher-interpreted-runtime-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.interpreted.pipes.ProcedureCallPipe.$anonfun$internalCreateResultsByAppending$2(ProcedureCallPipe.scala:73) ~[neo4j-cypher-interpreted-runtime-4.4.8.jar:4.4.8] at scala.collection.immutable.List.map(List.scala:297) ~[scala-library-2.12.13.jar:?] at org.neo4j.cypher.internal.runtime.interpreted.pipes.ProcedureCallPipe.$anonfun$internalCreateResultsByAppending$1(ProcedureCallPipe.scala:73) ~[neo4j-cypher-interpreted-runtime-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.ClosingIterator$$anon$1.nextCur(ClosingIterator.scala:107) ~[neo4j-cypher-runtime-util-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.ClosingIterator$$anon$1.innerHasNext(ClosingIterator.scala:113) ~[neo4j-cypher-runtime-util-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.ClosingIterator.hasNext(ClosingIterator.scala:93) ~[neo4j-cypher-runtime-util-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.ClosingIterator$$anon$3.innerHasNext(ClosingIterator.scala:152) ~[neo4j-cypher-runtime-util-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.ClosingIterator.hasNext(ClosingIterator.scala:93) ~[neo4j-cypher-runtime-util-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.interpreted.PipeExecutionResult.serveResults(PipeExecutionResult.scala:85) ~[neo4j-cypher-interpreted-runtime-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.interpreted.PipeExecutionResult.request(PipeExecutionResult.scala:73) ~[neo4j-cypher-interpreted-runtime-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.result.StandardInternalExecutionResult.request(StandardInternalExecutionResult.scala:90) ~[neo4j-cypher-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.result.ClosingExecutionResult.request(ClosingExecutionResult.scala:144) ~[neo4j-cypher-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.javacompat.ResultSubscriber.fetchResults(ResultSubscriber.java:362) ~[neo4j-cypher-4.4.8.jar:4.4.8] ... 63 more Suppressed: org.neo4j.graphdb.TransactionFailureException: Unable to complete transaction. at org.neo4j.fabric.executor.FabricLocalExecutor$LocalTransactionContext.transformTerminalOperationError(FabricLocalExecutor.java:237) ~[neo4j-fabric-4.4.8.jar:4.4.8] at org.neo4j.kernel.impl.coreapi.TransactionImpl.safeTerminalOperation(TransactionImpl.java:709) ~[neo4j-kernel-4.4.8.jar:4.4.8] at org.neo4j.kernel.impl.coreapi.TransactionImpl.rollback(TransactionImpl.java:189) ~[neo4j-kernel-4.4.8.jar:4.4.8] at org.neo4j.kernel.impl.query.Neo4jTransactionalContext.rollback(Neo4jTransactionalContext.java:144) ~[neo4j-kernel-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.interpreted.SingleThreadedTransactionalContextWrapper.rollback(TransactionalContextWrapper.scala:130) ~[neo4j-cypher-interpreted-runtime-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.interpreted.DelegatingQueryTransactionalContext.rollback(DelegatingQueryContext.scala:542) ~[neo4j-cypher-interpreted-runtime-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.planning.ExceptionTranslatingReadQueryContext$ExceptionTranslatingTransactionalContext.rollback(ExceptionTranslatingQueryContext.scala:392) ~[neo4j-cypher-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.CypherCurrentCompiler$CypherExecutableQuery.$anonfun$execute$1(CypherCurrentCompiler.scala:362) ~[neo4j-cypher-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.CypherCurrentCompiler$CypherExecutableQuery.$anonfun$execute$1$adapted(CypherCurrentCompiler.scala:359) ~[neo4j-cypher-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.util.TaskCloser.close(TaskCloser.scala:44) ~[neo4j-util-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.result.StandardInternalExecutionResult.close(StandardInternalExecutionResult.scala:87) ~[neo4j-cypher-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.result.ClosingExecutionResult.close(ClosingExecutionResult.scala:78) ~[neo4j-cypher-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.result.ClosingExecutionResult.closeAndCallOnError(ClosingExecutionResult.scala:117) ~[neo4j-cypher-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.result.ClosingExecutionResult.request(ClosingExecutionResult.scala:146) ~[neo4j-cypher-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.javacompat.ResultSubscriber.fetchResults(ResultSubscriber.java:362) ~[neo4j-cypher-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.javacompat.ResultSubscriber.nextFromSubscriber(ResultSubscriber.java:330) ~[neo4j-cypher-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.javacompat.ResultSubscriber.fetchNextOrNull(ResultSubscriber.java:301) ~[neo4j-cypher-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.javacompat.ResultSubscriber.fetchNextOrNull(ResultSubscriber.java:58) ~[neo4j-cypher-4.4.8.jar:4.4.8] at org.neo4j.internal.helpers.collection.PrefetchingIterator.peek(PrefetchingIterator.java:60) ~[neo4j-collections-4.4.8.jar:4.4.8] at org.neo4j.internal.helpers.collection.PrefetchingIterator.hasNext(PrefetchingIterator.java:46) ~[neo4j-collections-4.4.8.jar:4.4.8] at org.neo4j.internal.helpers.collection.Iterators.count(Iterators.java:383) ~[neo4j-collections-4.4.8.jar:4.4.8] at org.neo4j.internal.helpers.collection.Iterators.count(Iterators.java:369) ~[neo4j-collections-4.4.8.jar:4.4.8] at apoc.trigger.TriggerHandler.lambda$executeTriggers$14(TriggerHandler.java:267) ~[apoc-4.4.0.8.jar:4.4.0.8] at java.util.concurrent.ConcurrentHashMap.forEach(ConcurrentHashMap.java:1603) ~[?:?] at apoc.trigger.TriggerHandler.executeTriggers(TriggerHandler.java:257) ~[apoc-4.4.0.8.jar:4.4.0.8] at apoc.trigger.TriggerHandler.executeTriggers(TriggerHandler.java:252) ~[apoc-4.4.0.8.jar:4.4.0.8] at apoc.trigger.TriggerHandler.beforeCommit(TriggerHandler.java:209) ~[apoc-4.4.0.8.jar:4.4.0.8] at apoc.trigger.TriggerHandler.beforeCommit(TriggerHandler.java:40) ~[apoc-4.4.0.8.jar:4.4.0.8] at org.neo4j.kernel.internal.event.DatabaseTransactionEventListeners.beforeCommit(DatabaseTransactionEventListeners.java:101) ~[neo4j-kernel-4.4.8.jar:4.4.8] at org.neo4j.kernel.impl.api.KernelTransactionImplementation.commitTransaction(KernelTransactionImplementation.java:826) ~[neo4j-kernel-4.4.8.jar:4.4.8] at org.neo4j.kernel.impl.api.KernelTransactionImplementation.closeTransaction(KernelTransactionImplementation.java:736) ~[neo4j-kernel-4.4.8.jar:4.4.8] at org.neo4j.kernel.impl.api.KernelTransactionImplementation.commit(KernelTransactionImplementation.java:707) ~[neo4j-kernel-4.4.8.jar:4.4.8] at org.neo4j.kernel.impl.coreapi.TransactionImpl.lambda$commit$0(TransactionImpl.java:179) ~[neo4j-kernel-4.4.8.jar:4.4.8] at org.neo4j.kernel.impl.coreapi.TransactionImpl.safeTerminalOperation(TransactionImpl.java:700) ~[neo4j-kernel-4.4.8.jar:4.4.8] at org.neo4j.kernel.impl.coreapi.TransactionImpl.commit(TransactionImpl.java:174) ~[neo4j-kernel-4.4.8.jar:4.4.8] at org.neo4j.kernel.impl.coreapi.TransactionImpl.commit(TransactionImpl.java:169) ~[neo4j-kernel-4.4.8.jar:4.4.8] at org.neo4j.fabric.executor.FabricKernelTransaction.commit(FabricKernelTransaction.java:137) ~[neo4j-fabric-4.4.8.jar:4.4.8] at org.neo4j.fabric.executor.FabricLocalExecutor$KernelTxWrapper.doCommit(FabricLocalExecutor.java:269) ~[neo4j-fabric-4.4.8.jar:4.4.8] at reactor.core.publisher.MonoRunnable.call(MonoRunnable.java:73) ~[reactor-core-3.4.15.jar:3.4.15] at reactor.core.publisher.MonoRunnable.call(MonoRunnable.java:32) ~[reactor-core-3.4.15.jar:3.4.15] at reactor.core.publisher.FluxFlatMap.trySubscribeScalarMap(FluxFlatMap.java:127) ~[reactor-core-3.4.15.jar:3.4.15] at reactor.core.publisher.MonoFlatMap.subscribeOrReturn(MonoFlatMap.java:53) ~[reactor-core-3.4.15.jar:3.4.15] at reactor.core.publisher.Mono.subscribe(Mono.java:4385) ~[reactor-core-3.4.15.jar:3.4.15] at reactor.core.publisher.FluxFlatMap$FlatMapMain.onNext(FluxFlatMap.java:426) ~[reactor-core-3.4.15.jar:3.4.15] at reactor.core.publisher.FluxConcatArray$ConcatArraySubscriber.onNext(FluxConcatArray.java:201) ~[reactor-core-3.4.15.jar:3.4.15] at reactor.core.publisher.Operators$ScalarSubscription.request(Operators.java:2398) ~[reactor-core-3.4.15.jar:3.4.15] at reactor.core.publisher.FluxConcatArray$ConcatArraySubscriber.onSubscribe(FluxConcatArray.java:193) ~[reactor-core-3.4.15.jar:3.4.15] at reactor.core.publisher.MonoJust.subscribe(MonoJust.java:55) ~[reactor-core-3.4.15.jar:3.4.15] at reactor.core.publisher.Mono.subscribe(Mono.java:4400) ~[reactor-core-3.4.15.jar:3.4.15] at reactor.core.publisher.FluxConcatArray$ConcatArraySubscriber.onComplete(FluxConcatArray.java:258) ~[reactor-core-3.4.15.jar:3.4.15] at reactor.core.publisher.FluxConcatArray.subscribe(FluxConcatArray.java:78) ~[reactor-core-3.4.15.jar:3.4.15] at reactor.core.publisher.Mono.subscribe(Mono.java:4400) ~[reactor-core-3.4.15.jar:3.4.15] at reactor.core.publisher.Mono.block(Mono.java:1706) ~[reactor-core-3.4.15.jar:3.4.15] at org.neo4j.fabric.transaction.FabricTransactionImpl.doOnChildren(FabricTransactionImpl.java:296) ~[neo4j-fabric-4.4.8.jar:4.4.8] at org.neo4j.fabric.transaction.FabricTransactionImpl.commit(FabricTransactionImpl.java:207) ~[neo4j-fabric-4.4.8.jar:4.4.8] at org.neo4j.fabric.bolt.BoltFabricDatabaseService$BoltTransactionImpl.commit(BoltFabricDatabaseService.java:146) ~[neo4j-fabric-4.4.8.jar:4.4.8] at org.neo4j.bolt.runtime.statemachine.impl.TransactionStateMachine$State.closeTransaction(TransactionStateMachine.java:406) ~[neo4j-bolt-4.4.8.jar:4.4.8] at org.neo4j.bolt.runtime.statemachine.impl.TransactionStateMachine$State$2.commitTransaction(TransactionStateMachine.java:358) ~[neo4j-bolt-4.4.8.jar:4.4.8] at org.neo4j.bolt.runtime.statemachine.impl.TransactionStateMachine.commitTransaction(TransactionStateMachine.java:108) ~[neo4j-bolt-4.4.8.jar:4.4.8] at org.neo4j.bolt.transaction.StatementProcessorTxManager.commit(StatementProcessorTxManager.java:66) ~[neo4j-bolt-4.4.8.jar:4.4.8] at org.neo4j.bolt.v4.runtime.InTransactionState.processCommitMessage(InTransactionState.java:107) ~[neo4j-bolt-4.4.8.jar:4.4.8] at org.neo4j.bolt.v44.runtime.InTransactionState.processCommitMessage(InTransactionState.java:35) ~[neo4j-bolt-4.4.8.jar:4.4.8] at org.neo4j.bolt.v4.runtime.InTransactionState.processUnsafe(InTransactionState.java:56) ~[neo4j-bolt-4.4.8.jar:4.4.8] at org.neo4j.bolt.v3.runtime.FailSafeBoltStateMachineState.process(FailSafeBoltStateMachineState.java:48) ~[neo4j-bolt-4.4.8.jar:4.4.8] at org.neo4j.bolt.runtime.statemachine.impl.AbstractBoltStateMachine.nextState(AbstractBoltStateMachine.java:154) ~[neo4j-bolt-4.4.8.jar:4.4.8] at org.neo4j.bolt.runtime.statemachine.impl.AbstractBoltStateMachine.process(AbstractBoltStateMachine.java:102) ~[neo4j-bolt-4.4.8.jar:4.4.8] at org.neo4j.bolt.messaging.BoltRequestMessageReader.lambda$doRead$1(BoltRequestMessageReader.java:93) ~[neo4j-bolt-4.4.8.jar:4.4.8] at org.neo4j.bolt.runtime.DefaultBoltConnection.lambda$enqueue$0(DefaultBoltConnection.java:156) ~[neo4j-bolt-4.4.8.jar:4.4.8] at org.neo4j.bolt.runtime.DefaultBoltConnection.processNextBatchInternal(DefaultBoltConnection.java:252) ~[neo4j-bolt-4.4.8.jar:4.4.8] at org.neo4j.bolt.runtime.DefaultBoltConnection.processNextBatch(DefaultBoltConnection.java:187) ~[neo4j-bolt-4.4.8.jar:4.4.8] at org.neo4j.bolt.runtime.DefaultBoltConnection.processNextBatch(DefaultBoltConnection.java:177) ~[neo4j-bolt-4.4.8.jar:4.4.8] at org.neo4j.bolt.runtime.scheduling.ExecutorBoltScheduler.executeBatch(ExecutorBoltScheduler.java:257) ~[neo4j-bolt-4.4.8.jar:4.4.8] at org.neo4j.bolt.runtime.scheduling.ExecutorBoltScheduler.lambda$scheduleBatchOrHandleError$3(ExecutorBoltScheduler.java:240) ~[neo4j-bolt-4.4.8.jar:4.4.8] at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1700) [?:?] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) [?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) [?:?] at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) [netty-common-4.1.75.Final.jar:4.1.75.Final] at java.lang.Thread.run(Thread.java:829) [?:?] Caused by: java.lang.IllegalStateException: This transaction is already being closed. at org.neo4j.kernel.impl.api.KernelTransactionImplementation.assertTransactionNotClosing(KernelTransactionImplementation.java:674) ~[neo4j-kernel-4.4.8.jar:4.4.8] at org.neo4j.kernel.impl.api.KernelTransactionImplementation.closeTransaction(KernelTransactionImplementation.java:728) ~[neo4j-kernel-4.4.8.jar:4.4.8] at org.neo4j.kernel.impl.api.KernelTransactionImplementation.rollback(KernelTransactionImplementation.java:721) ~[neo4j-kernel-4.4.8.jar:4.4.8] at org.neo4j.kernel.impl.coreapi.TransactionImpl.lambda$rollback$1(TransactionImpl.java:194) ~[neo4j-kernel-4.4.8.jar:4.4.8] at org.neo4j.kernel.impl.coreapi.TransactionImpl.safeTerminalOperation(TransactionImpl.java:700) ~[neo4j-kernel-4.4.8.jar:4.4.8] ... 76 more Caused by: org.neo4j.internal.kernel.api.exceptions.ProcedureException: Failed to invoke function apoc.convert.toJson: Caused by: org.neo4j.internal.kernel.api.exceptions.EntityNotFoundException: Unable to load NODE with id 7448. at org.neo4j.procedure.impl.ProcedureCompilation.rethrowProcedureException(ProcedureCompilation.java:534) ~[neo4j-procedure-4.4.8.jar:4.4.8] at org.neo4j.kernel.impl.proc.GeneratedFunction_toJson4123796354572283.apply(Unknown Source) ~[?:?] at org.neo4j.procedure.impl.ProcedureRegistry.callFunction(ProcedureRegistry.java:250) ~[neo4j-procedure-4.4.8.jar:4.4.8] at org.neo4j.procedure.impl.GlobalProceduresRegistry.callFunction(GlobalProceduresRegistry.java:358) ~[neo4j-procedure-4.4.8.jar:4.4.8] at org.neo4j.kernel.impl.newapi.AllStoreHolder.callFunction(AllStoreHolder.java:1139) ~[neo4j-kernel-4.4.8.jar:4.4.8] at org.neo4j.kernel.impl.newapi.AllStoreHolder.functionCall(AllStoreHolder.java:1031) ~[neo4j-kernel-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.interpreted.CallSupport$.callFunction(CallSupport.scala:38) ~[neo4j-cypher-interpreted-runtime-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.interpreted.TransactionBoundReadQueryContext.callFunction(TransactionBoundQueryContext.scala:1150) ~[neo4j-cypher-interpreted-runtime-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.planning.ExceptionTranslatingReadQueryContext.callFunction(ExceptionTranslatingQueryContext.scala:237) ~[neo4j-cypher-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.interpreted.commands.expressions.UserFunctionInvocation.call(FunctionInvocation.scala:58) ~[neo4j-cypher-interpreted-runtime-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.interpreted.commands.expressions.FunctionInvocation.apply(FunctionInvocation.scala:42) ~[neo4j-cypher-interpreted-runtime-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.interpreted.commands.expressions.CoerceTo.apply(CoerceTo.scala:31) ~[neo4j-cypher-interpreted-runtime-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.interpreted.pipes.ProcedureCallPipe.$anonfun$internalCreateResultsByAppending$2(ProcedureCallPipe.scala:73) ~[neo4j-cypher-interpreted-runtime-4.4.8.jar:4.4.8] at scala.collection.immutable.List.map(List.scala:297) ~[scala-library-2.12.13.jar:?] at org.neo4j.cypher.internal.runtime.interpreted.pipes.ProcedureCallPipe.$anonfun$internalCreateResultsByAppending$1(ProcedureCallPipe.scala:73) ~[neo4j-cypher-interpreted-runtime-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.ClosingIterator$$anon$1.nextCur(ClosingIterator.scala:107) ~[neo4j-cypher-runtime-util-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.ClosingIterator$$anon$1.innerHasNext(ClosingIterator.scala:113) ~[neo4j-cypher-runtime-util-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.ClosingIterator.hasNext(ClosingIterator.scala:93) ~[neo4j-cypher-runtime-util-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.ClosingIterator$$anon$3.innerHasNext(ClosingIterator.scala:152) ~[neo4j-cypher-runtime-util-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.ClosingIterator.hasNext(ClosingIterator.scala:93) ~[neo4j-cypher-runtime-util-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.interpreted.PipeExecutionResult.serveResults(PipeExecutionResult.scala:85) ~[neo4j-cypher-interpreted-runtime-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.interpreted.PipeExecutionResult.request(PipeExecutionResult.scala:73) ~[neo4j-cypher-interpreted-runtime-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.result.StandardInternalExecutionResult.request(StandardInternalExecutionResult.scala:90) ~[neo4j-cypher-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.result.ClosingExecutionResult.request(ClosingExecutionResult.scala:144) ~[neo4j-cypher-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.javacompat.ResultSubscriber.fetchResults(ResultSubscriber.java:362) ~[neo4j-cypher-4.4.8.jar:4.4.8] ... 63 more Caused by: org.neo4j.graphdb.NotFoundException: org.neo4j.internal.kernel.api.exceptions.EntityNotFoundException: Unable to load NODE with id 7448. at org.neo4j.kernel.impl.core.NodeEntity.singleNode(NodeEntity.java:790) ~[neo4j-kernel-4.4.8.jar:4.4.8] at org.neo4j.kernel.impl.core.NodeEntity.getLabels(NodeEntity.java:620) ~[neo4j-kernel-4.4.8.jar:4.4.8] at org.neo4j.kernel.impl.core.NodeEntity.getLabels(NodeEntity.java:612) ~[neo4j-kernel-4.4.8.jar:4.4.8] at apoc.convert.Json.nodeToMap(Json.java:68) ~[apoc-4.4.0.8.jar:4.4.0.8] at apoc.convert.Json.relToMap(Json.java:57) ~[apoc-4.4.0.8.jar:4.4.0.8] at apoc.convert.Json.writeJsonResult(Json.java:34) ~[apoc-4.4.0.8.jar:4.4.0.8] at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195) ~[?:?] at java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1655) ~[?:?] at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:484) ~[?:?] at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474) ~[?:?] at java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:913) ~[?:?] at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) ~[?:?] at java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:578) ~[?:?] at apoc.convert.Json.writeJsonResult(Json.java:40) ~[apoc-4.4.0.8.jar:4.4.0.8] at apoc.convert.Json.lambda$writeJsonResult$1(Json.java:45) ~[apoc-4.4.0.8.jar:4.4.0.8] at java.util.stream.ReduceOps$4ReducingSink.accept(ReduceOps.java:220) ~[?:?] at java.util.HashMap$EntrySpliterator.forEachRemaining(HashMap.java:1764) ~[?:?] at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:484) ~[?:?] at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474) ~[?:?] at java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:913) ~[?:?] at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) ~[?:?] at java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:589) ~[?:?] at apoc.convert.Json.writeJsonResult(Json.java:44) ~[apoc-4.4.0.8.jar:4.4.0.8] at apoc.convert.Json.lambda$writeJsonResult$1(Json.java:45) ~[apoc-4.4.0.8.jar:4.4.0.8] at java.util.stream.ReduceOps$4ReducingSink.accept(ReduceOps.java:220) ~[?:?] at java.util.HashMap$EntrySpliterator.forEachRemaining(HashMap.java:1764) ~[?:?] at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:484) ~[?:?] at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474) ~[?:?] at java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:913) ~[?:?] at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) ~[?:?] at java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:589) ~[?:?] at apoc.convert.Json.writeJsonResult(Json.java:44) ~[apoc-4.4.0.8.jar:4.4.0.8] at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195) ~[?:?] at java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1655) ~[?:?] at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:484) ~[?:?] at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474) ~[?:?] at java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:913) ~[?:?] at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) ~[?:?] at java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:578) ~[?:?] at apoc.convert.Json.writeJsonResult(Json.java:40) ~[apoc-4.4.0.8.jar:4.4.0.8] at apoc.convert.Json.lambda$writeJsonResult$1(Json.java:45) ~[apoc-4.4.0.8.jar:4.4.0.8] at java.util.stream.ReduceOps$4ReducingSink.accept(ReduceOps.java:220) ~[?:?] at java.util.HashMap$EntrySpliterator.forEachRemaining(HashMap.java:1764) ~[?:?] at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:484) ~[?:?] at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474) ~[?:?] at java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:913) ~[?:?] at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) ~[?:?] at java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:589) ~[?:?] at apoc.convert.Json.writeJsonResult(Json.java:44) ~[apoc-4.4.0.8.jar:4.4.0.8] at apoc.convert.Json.toJson(Json.java:93) ~[apoc-4.4.0.8.jar:4.4.0.8] at org.neo4j.kernel.impl.proc.GeneratedFunction_toJson4123796354572283.apply(Unknown Source) ~[?:?] at org.neo4j.procedure.impl.ProcedureRegistry.callFunction(ProcedureRegistry.java:250) ~[neo4j-procedure-4.4.8.jar:4.4.8] at org.neo4j.procedure.impl.GlobalProceduresRegistry.callFunction(GlobalProceduresRegistry.java:358) ~[neo4j-procedure-4.4.8.jar:4.4.8] at org.neo4j.kernel.impl.newapi.AllStoreHolder.callFunction(AllStoreHolder.java:1139) ~[neo4j-kernel-4.4.8.jar:4.4.8] at org.neo4j.kernel.impl.newapi.AllStoreHolder.functionCall(AllStoreHolder.java:1031) ~[neo4j-kernel-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.interpreted.CallSupport$.callFunction(CallSupport.scala:38) ~[neo4j-cypher-interpreted-runtime-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.interpreted.TransactionBoundReadQueryContext.callFunction(TransactionBoundQueryContext.scala:1150) ~[neo4j-cypher-interpreted-runtime-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.planning.ExceptionTranslatingReadQueryContext.callFunction(ExceptionTranslatingQueryContext.scala:237) ~[neo4j-cypher-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.interpreted.commands.expressions.UserFunctionInvocation.call(FunctionInvocation.scala:58) ~[neo4j-cypher-interpreted-runtime-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.interpreted.commands.expressions.FunctionInvocation.apply(FunctionInvocation.scala:42) ~[neo4j-cypher-interpreted-runtime-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.interpreted.commands.expressions.CoerceTo.apply(CoerceTo.scala:31) ~[neo4j-cypher-interpreted-runtime-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.interpreted.pipes.ProcedureCallPipe.$anonfun$internalCreateResultsByAppending$2(ProcedureCallPipe.scala:73) ~[neo4j-cypher-interpreted-runtime-4.4.8.jar:4.4.8] at scala.collection.immutable.List.map(List.scala:297) ~[scala-library-2.12.13.jar:?] at org.neo4j.cypher.internal.runtime.interpreted.pipes.ProcedureCallPipe.$anonfun$internalCreateResultsByAppending$1(ProcedureCallPipe.scala:73) ~[neo4j-cypher-interpreted-runtime-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.ClosingIterator$$anon$1.nextCur(ClosingIterator.scala:107) ~[neo4j-cypher-runtime-util-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.ClosingIterator$$anon$1.innerHasNext(ClosingIterator.scala:113) ~[neo4j-cypher-runtime-util-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.ClosingIterator.hasNext(ClosingIterator.scala:93) ~[neo4j-cypher-runtime-util-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.ClosingIterator$$anon$3.innerHasNext(ClosingIterator.scala:152) ~[neo4j-cypher-runtime-util-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.ClosingIterator.hasNext(ClosingIterator.scala:93) ~[neo4j-cypher-runtime-util-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.interpreted.PipeExecutionResult.serveResults(PipeExecutionResult.scala:85) ~[neo4j-cypher-interpreted-runtime-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.interpreted.PipeExecutionResult.request(PipeExecutionResult.scala:73) ~[neo4j-cypher-interpreted-runtime-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.result.StandardInternalExecutionResult.request(StandardInternalExecutionResult.scala:90) ~[neo4j-cypher-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.result.ClosingExecutionResult.request(ClosingExecutionResult.scala:144) ~[neo4j-cypher-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.javacompat.ResultSubscriber.fetchResults(ResultSubscriber.java:362) ~[neo4j-cypher-4.4.8.jar:4.4.8] ... 63 more Caused by: org.neo4j.internal.kernel.api.exceptions.EntityNotFoundException: Unable to load NODE with id 7448. at org.neo4j.kernel.impl.core.NodeEntity.singleNode(NodeEntity.java:790) ~[neo4j-kernel-4.4.8.jar:4.4.8] at org.neo4j.kernel.impl.core.NodeEntity.getLabels(NodeEntity.java:620) ~[neo4j-kernel-4.4.8.jar:4.4.8] at org.neo4j.kernel.impl.core.NodeEntity.getLabels(NodeEntity.java:612) ~[neo4j-kernel-4.4.8.jar:4.4.8] at apoc.convert.Json.nodeToMap(Json.java:68) ~[apoc-4.4.0.8.jar:4.4.0.8] at apoc.convert.Json.relToMap(Json.java:57) ~[apoc-4.4.0.8.jar:4.4.0.8] at apoc.convert.Json.writeJsonResult(Json.java:34) ~[apoc-4.4.0.8.jar:4.4.0.8] at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195) ~[?:?] at java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1655) ~[?:?] at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:484) ~[?:?] at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474) ~[?:?] at java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:913) ~[?:?] at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) ~[?:?] at java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:578) ~[?:?] at apoc.convert.Json.writeJsonResult(Json.java:40) ~[apoc-4.4.0.8.jar:4.4.0.8] at apoc.convert.Json.lambda$writeJsonResult$1(Json.java:45) ~[apoc-4.4.0.8.jar:4.4.0.8] at java.util.stream.ReduceOps$4ReducingSink.accept(ReduceOps.java:220) ~[?:?] at java.util.HashMap$EntrySpliterator.forEachRemaining(HashMap.java:1764) ~[?:?] at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:484) ~[?:?] at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474) ~[?:?] at java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:913) ~[?:?] at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) ~[?:?] at java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:589) ~[?:?] at apoc.convert.Json.writeJsonResult(Json.java:44) ~[apoc-4.4.0.8.jar:4.4.0.8] at apoc.convert.Json.lambda$writeJsonResult$1(Json.java:45) ~[apoc-4.4.0.8.jar:4.4.0.8] at java.util.stream.ReduceOps$4ReducingSink.accept(ReduceOps.java:220) ~[?:?] at java.util.HashMap$EntrySpliterator.forEachRemaining(HashMap.java:1764) ~[?:?] at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:484) ~[?:?] at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474) ~[?:?] at java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:913) ~[?:?] at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) ~[?:?] at java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:589) ~[?:?] at apoc.convert.Json.writeJsonResult(Json.java:44) ~[apoc-4.4.0.8.jar:4.4.0.8] at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195) ~[?:?] at java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1655) ~[?:?] at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:484) ~[?:?] at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474) ~[?:?] at java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:913) ~[?:?] at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) ~[?:?] at java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:578) ~[?:?] at apoc.convert.Json.writeJsonResult(Json.java:40) ~[apoc-4.4.0.8.jar:4.4.0.8] at apoc.convert.Json.lambda$writeJsonResult$1(Json.java:45) ~[apoc-4.4.0.8.jar:4.4.0.8] at java.util.stream.ReduceOps$4ReducingSink.accept(ReduceOps.java:220) ~[?:?] at java.util.HashMap$EntrySpliterator.forEachRemaining(HashMap.java:1764) ~[?:?] at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:484) ~[?:?] at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474) ~[?:?] at java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:913) ~[?:?] at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) ~[?:?] at java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:589) ~[?:?] at apoc.convert.Json.writeJsonResult(Json.java:44) ~[apoc-4.4.0.8.jar:4.4.0.8] at apoc.convert.Json.toJson(Json.java:93) ~[apoc-4.4.0.8.jar:4.4.0.8] at org.neo4j.kernel.impl.proc.GeneratedFunction_toJson4123796354572283.apply(Unknown Source) ~[?:?] at org.neo4j.procedure.impl.ProcedureRegistry.callFunction(ProcedureRegistry.java:250) ~[neo4j-procedure-4.4.8.jar:4.4.8] at org.neo4j.procedure.impl.GlobalProceduresRegistry.callFunction(GlobalProceduresRegistry.java:358) ~[neo4j-procedure-4.4.8.jar:4.4.8] at org.neo4j.kernel.impl.newapi.AllStoreHolder.callFunction(AllStoreHolder.java:1139) ~[neo4j-kernel-4.4.8.jar:4.4.8] at org.neo4j.kernel.impl.newapi.AllStoreHolder.functionCall(AllStoreHolder.java:1031) ~[neo4j-kernel-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.interpreted.CallSupport$.callFunction(CallSupport.scala:38) ~[neo4j-cypher-interpreted-runtime-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.interpreted.TransactionBoundReadQueryContext.callFunction(TransactionBoundQueryContext.scala:1150) ~[neo4j-cypher-interpreted-runtime-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.planning.ExceptionTranslatingReadQueryContext.callFunction(ExceptionTranslatingQueryContext.scala:237) ~[neo4j-cypher-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.interpreted.commands.expressions.UserFunctionInvocation.call(FunctionInvocation.scala:58) ~[neo4j-cypher-interpreted-runtime-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.interpreted.commands.expressions.FunctionInvocation.apply(FunctionInvocation.scala:42) ~[neo4j-cypher-interpreted-runtime-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.interpreted.commands.expressions.CoerceTo.apply(CoerceTo.scala:31) ~[neo4j-cypher-interpreted-runtime-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.interpreted.pipes.ProcedureCallPipe.$anonfun$internalCreateResultsByAppending$2(ProcedureCallPipe.scala:73) ~[neo4j-cypher-interpreted-runtime-4.4.8.jar:4.4.8] at scala.collection.immutable.List.map(List.scala:297) ~[scala-library-2.12.13.jar:?] at org.neo4j.cypher.internal.runtime.interpreted.pipes.ProcedureCallPipe.$anonfun$internalCreateResultsByAppending$1(ProcedureCallPipe.scala:73) ~[neo4j-cypher-interpreted-runtime-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.ClosingIterator$$anon$1.nextCur(ClosingIterator.scala:107) ~[neo4j-cypher-runtime-util-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.ClosingIterator$$anon$1.innerHasNext(ClosingIterator.scala:113) ~[neo4j-cypher-runtime-util-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.ClosingIterator.hasNext(ClosingIterator.scala:93) ~[neo4j-cypher-runtime-util-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.ClosingIterator$$anon$3.innerHasNext(ClosingIterator.scala:152) ~[neo4j-cypher-runtime-util-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.ClosingIterator.hasNext(ClosingIterator.scala:93) ~[neo4j-cypher-runtime-util-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.interpreted.PipeExecutionResult.serveResults(PipeExecutionResult.scala:85) ~[neo4j-cypher-interpreted-runtime-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.runtime.interpreted.PipeExecutionResult.request(PipeExecutionResult.scala:73) ~[neo4j-cypher-interpreted-runtime-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.result.StandardInternalExecutionResult.request(StandardInternalExecutionResult.scala:90) ~[neo4j-cypher-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.result.ClosingExecutionResult.request(ClosingExecutionResult.scala:144) ~[neo4j-cypher-4.4.8.jar:4.4.8] at org.neo4j.cypher.internal.javacompat.ResultSubscriber.fetchResults(ResultSubscriber.java:362) ~[neo4j-cypher-4.4.8.jar:4.4.8] ... 63 more