diff --git a/sql/core/src/main/scala/org/apache/spark/sql/UpdateWriter.scala b/sql/core/src/main/scala/org/apache/spark/sql/UpdateWriter.scala index 614ee579c0538..806f524954224 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/UpdateWriter.scala +++ b/sql/core/src/main/scala/org/apache/spark/sql/UpdateWriter.scala @@ -49,7 +49,7 @@ class UpdateWriter[T](dataset: Dataset[T], assignments: Map[String, Column]) { * Executes the update operation. */ def execute(): Unit = { - new UpdateWithCondition(dataset, assignments, None) + new UpdateWithCondition(dataset, assignments, None).execute() } }