Skip to content

Commit edbdcbd

Browse files
committed
nit: style
1 parent 7eb2fec commit edbdcbd

1 file changed

Lines changed: 2 additions & 5 deletions

File tree

externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/kyuubi/engine/spark/util/SparkCatalogUtils.scala

Lines changed: 2 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -95,12 +95,9 @@ object SparkCatalogUtils extends Logging {
9595
}
9696

9797
def setCurrentCatalog(spark: SparkSession, catalog: String): Unit = {
98-
// SPARK-36841(3.3.0) Ensure setCurrentCatalog method catalog must exist
98+
// SPARK-36841 (3.3.0) Ensure setCurrentCatalog method catalog must exist
9999
if (isCatalogRegistered(spark, catalog)) {
100-
invokeAs[Unit](
101-
catalogManager(spark),
102-
"setCurrentCatalog",
103-
(classOf[String], catalog))
100+
invokeAs[Unit](catalogManager(spark), "setCurrentCatalog", (classOf[String], catalog))
104101
} else {
105102
throw new IllegalArgumentException(s"Cannot find catalog plugin class for catalog '$catalog'")
106103
}

0 commit comments

Comments
 (0)