diff --git a/src/main/java/org/springframework/data/neo4j/core/mapping/DefaultNeo4jPersistentEntity.java b/src/main/java/org/springframework/data/neo4j/core/mapping/DefaultNeo4jPersistentEntity.java index 5586fd5b8..367aa4322 100644 --- a/src/main/java/org/springframework/data/neo4j/core/mapping/DefaultNeo4jPersistentEntity.java +++ b/src/main/java/org/springframework/data/neo4j/core/mapping/DefaultNeo4jPersistentEntity.java @@ -470,8 +470,9 @@ final class DefaultNeo4jPersistentEntity extends BasicPersistentEntity { String fieldName = concreteRelationship.getFieldName(); + NodeDescription target = concreteRelationship.getTarget(); - if (relationships.stream().noneMatch(relationship -> relationship.getFieldName().equals(fieldName))) { + if (relationships.stream().noneMatch(relationship -> relationship.getFieldName().equals(fieldName) && relationship.getTarget().equals(target))) { relationships.add(concreteRelationship); } });