From 3518a9809687f99a861f96a3d62d839ff6a71e9c Mon Sep 17 00:00:00 2001 From: Enrico Minack Date: Tue, 23 Jan 2024 09:49:22 +0100 Subject: [PATCH] Fix minor typo --- .../apache/spark/sql/execution/datasources/jdbc/JdbcUtils.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc/JdbcUtils.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc/JdbcUtils.scala index a2f276c45c40e..7090b9ca078b4 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc/JdbcUtils.scala +++ b/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc/JdbcUtils.scala @@ -1064,7 +1064,7 @@ object JdbcUtils extends Logging with SQLConfHelper { dialect.createTable(statement, tableName, strSchema, options) } if (options.isUpsert) { - // creating a table that is going to be upserted requires a primary index + // creating a table that is going to be upsert requires a primary index assert(mergeDialect.isDefined) mergeDialect.foreach(_.createPrimaryIndex(statement, tableName, options.upsertKeyColumns)) }