I use apoc.periodic.iterate function:
CALL apoc.periodic.iterate(
"load csv from 'file:///user_friends.csv' as line with toInteger(line[1]) as start_id, toInteger(line[0]) as end_id match (a:User{id:start_id}),(b:User{id:end_id}) return a,b ",
"where a is not null and b is not null merge (a)-[f:FOLLOWS]->(b) on create set f.update_date=date('2019-06-10') on match set f.update_date=date('2019-06-10')",
{batchSize:20000, parallel:true, concurrency:20, iterateList:true})
I run this query two time and get two errors:
(1)
errorMessages column was empty
batch column:
{
"total": 307,
"committed": 76,
"failed": 231,
"errors": {
"java.lang.NullPointerException": 231
}
}
operations column:
{
"total": 3064913,
"committed": 760000,
"failed": 2310000,
"errors": {
}
}
(2)
column column:
{
"total": 154,
"committed": 21,
"failed": 133,
"errors": {
"org.neo4j.kernel.DeadlockDetectedException: ForsetiClient[2] can't acquire ExclusiveLock{owner=ForsetiClient[18]} on RELATIONSHIP(6416563251), because holders of that lock are waiting for ForsetiClient[2].
Wait list:ExclusiveLock[
Client[18] waits for [2,13]]": 1,
"java.lang.NullPointerException": 132
}
}
operations column:
{
"total": 3064913,
"committed": 420000,
"failed": 2640000,
"errors": {
}
}
what means these errors? how can I change my query to avoid errors?
