Skip to content

Commit e769061

Browse files
committed
Fix style
1 parent 0cd632e commit e769061

File tree

1 file changed

+5
-6
lines changed

1 file changed

+5
-6
lines changed

sql/connect/server/src/test/scala/org/apache/spark/sql/connect/service/SparkConnectSessionHolderSuite.scala

Lines changed: 5 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -48,16 +48,15 @@ class SparkConnectSessionHolderSuite extends SharedSparkSession {
4848
test("SessionHolder.close should close catalogs") {
4949
val sessionHolder = SparkConnectTestUtils.createDummySessionHolder(spark)
5050
val catalogName = "my_closeable_catalog"
51-
sessionHolder.session.conf.set(
52-
s"spark.sql.catalog.$catalogName",
53-
classOf[CloseableCatalog].getName)
51+
sessionHolder.session.conf
52+
.set(s"spark.sql.catalog.$catalogName", classOf[CloseableCatalog].getName)
5453

5554
val catalog = sessionHolder.session.sessionState.catalogManager.catalog(catalogName)
5655
val closeableCatalog = catalog.asInstanceOf[CloseableCatalog]
5756
assert(!closeableCatalog.isClosed)
5857
sessionHolder.close()
5958
assert(closeableCatalog.isClosed)
60-
}
59+
}
6160

6261
test("DataFrame cache: Successful put and get") {
6362
val sessionHolder = SparkConnectTestUtils.createDummySessionHolder(spark)
@@ -501,7 +500,7 @@ class SparkConnectSessionHolderSuite extends SharedSparkSession {
501500
}
502501

503502
class CloseableCatalog
504-
extends org.apache.spark.sql.connector.catalog.CatalogPlugin
503+
extends org.apache.spark.sql.connector.catalog.CatalogPlugin
505504
with java.io.Closeable {
506505
private var _name: String = _
507506
private var closed = false
@@ -516,4 +515,4 @@ class CloseableCatalog
516515
}
517516

518517
def isClosed: Boolean = closed
519-
}
518+
}

0 commit comments

Comments
 (0)