Skip to content

Commit 6d530a9

Browse files
author
Andrew Or
committed
Fix tests
1 parent 2118212 commit 6d530a9

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/catalog/CatalogTestCases.scala

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -78,7 +78,7 @@ abstract class CatalogTestCases extends SparkFunSuite with BeforeAndAfterEach {
7878
catalog.createTable("db2", newTable("tbl1", "db2"), ignoreIfExists = false)
7979
catalog.createTable("db2", newTable("tbl2", "db2"), ignoreIfExists = false)
8080
catalog.createPartitions("db2", "tbl2", Seq(part1, part2), ignoreIfExists = false)
81-
catalog.createFunction("db2", newFunc("func1"))
81+
catalog.createFunction("db2", newFunc("func1", Some("db2")))
8282
catalog
8383
}
8484

@@ -97,8 +97,8 @@ abstract class CatalogTestCases extends SparkFunSuite with BeforeAndAfterEach {
9797
partitionColumns = Seq(CatalogColumn("a", "int"), CatalogColumn("b", "string")))
9898
}
9999

100-
private def newFunc(name: String): CatalogFunction = {
101-
CatalogFunction(FunctionIdentifier(name, database = None), funcClass)
100+
private def newFunc(name: String, database: Option[String] = None): CatalogFunction = {
101+
CatalogFunction(FunctionIdentifier(name, database), funcClass)
102102
}
103103

104104
/**

0 commit comments

Comments
 (0)