Skip to content

Commit b04efc5

Browse files
author
xieshuaihu
committed
[SPARK-45538][PYTHON][CONNECT]pyspark connect overwrite_partitions bug
1 parent c35ca7c commit b04efc5

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

python/pyspark/sql/connect/plan.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1743,7 +1743,7 @@ def command(self, session: "SparkConnectClient") -> proto.Command:
17431743
plan.write_operation_v2.mode = proto.WriteOperationV2.Mode.MODE_CREATE
17441744
elif wm == "overwrite":
17451745
plan.write_operation_v2.mode = proto.WriteOperationV2.Mode.MODE_OVERWRITE
1746-
elif wm == "overwrite_partition":
1746+
elif wm == "overwrite_partitions":
17471747
plan.write_operation_v2.mode = proto.WriteOperationV2.Mode.MODE_OVERWRITE_PARTITIONS
17481748
elif wm == "append":
17491749
plan.write_operation_v2.mode = proto.WriteOperationV2.Mode.MODE_APPEND

0 commit comments

Comments
 (0)