Fix unit test

szehon-ho · Aug 8, 2024 · 4b89b74 · 4b89b74
1 parent a56228c
commit 4b89b74
Showing 1 changed file with 1 addition and 1 deletion.
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
@@ -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()
   }
 }