Skip to content

Commit 583d349

Browse files
committed
Fix lint and test compile error after merge
1 parent eb9571b commit 583d349

File tree

3 files changed

+5
-3
lines changed

3 files changed

+5
-3
lines changed

sql/core/src/main/scala/org/apache/spark/sql/jdbc/H2Dialect.scala

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -36,7 +36,8 @@ import org.apache.spark.sql.connector.expressions.{Expression, FieldReference, N
3636
import org.apache.spark.sql.execution.datasources.jdbc.{JDBCOptions, JdbcOptionsInWrite, JdbcUtils}
3737
import org.apache.spark.sql.types.{BooleanType, ByteType, DataType, DecimalType, MetadataBuilder, ShortType, StringType, TimestampType}
3838

39-
private[sql] case class H2Dialect() extends JdbcDialect with MergeByTempTable with NoLegacyJDBCError {
39+
private[sql] case class H2Dialect() extends JdbcDialect with MergeByTempTable
40+
with NoLegacyJDBCError {
4041
override def canHandle(url: String): Boolean =
4142
url.toLowerCase(Locale.ROOT).startsWith("jdbc:h2")
4243

sql/core/src/main/scala/org/apache/spark/sql/jdbc/MsSqlServerDialect.scala

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -34,7 +34,8 @@ import org.apache.spark.sql.jdbc.MsSqlServerDialect.{GEOGRAPHY, GEOMETRY}
3434
import org.apache.spark.sql.types._
3535

3636

37-
private case class MsSqlServerDialect() extends JdbcDialect with MergeByTempTable with NoLegacyJDBCError {
37+
private case class MsSqlServerDialect() extends JdbcDialect with MergeByTempTable
38+
with NoLegacyJDBCError {
3839
override def canHandle(url: String): Boolean =
3940
url.toLowerCase(Locale.ROOT).startsWith("jdbc:sqlserver")
4041

sql/core/src/test/scala/org/apache/spark/sql/jdbc/JDBCWriteSuite.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -209,7 +209,7 @@ class JDBCWriteSuite extends SharedSparkSession with BeforeAndAfter {
209209
}
210210

211211
test("Upsert") {
212-
JdbcDialects.registerDialect(H2Dialect)
212+
JdbcDialects.registerDialect(H2Dialect())
213213
val table = "upsert"
214214
spark
215215
.range(10)

0 commit comments

Comments
 (0)