Skip to content

Commit e12a3ca

Browse files
MAndrews_leviMAndrews_levi
authored andcommitted
build_relationship bug fix
1 parent 3eccbb5 commit e12a3ca

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

neo4j_parallel_spark_loader/utils/build_relationship.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -70,7 +70,8 @@ def build_relationship(
7070
else:
7171
print("Building in series")
7272
df = (
73-
df.write.format("org.neo4j.spark.DataSource")
73+
df.coalesce(1)
74+
.write.format("org.neo4j.spark.DataSource")
7475
.mode("Overwrite")
7576
.options(**options)
7677
.save()

0 commit comments

Comments
 (0)