Skip to content

Commit 268f765

Browse files
committed
Change db name
1 parent 48cccf1 commit 268f765

File tree

1 file changed

+6
-6
lines changed

1 file changed

+6
-6
lines changed

spark/src/test/scala/ai/chronon/spark/test/TableUtilsFormatTest.scala

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -22,8 +22,8 @@ class TableUtilsFormatTest {
2222

2323
@Test
2424
def testInsertPartitionsAddColumns(): Unit = {
25-
val tableName = s"db.test_table_1_$format"
26-
spark.sql("CREATE DATABASE IF NOT EXISTS db")
25+
val tableName = s"db_format.test_table_1_$format"
26+
spark.sql("CREATE DATABASE IF NOT EXISTS db_format")
2727
val columns1 = Array(
2828
StructField("long_field", LongType),
2929
StructField("int_field", IntType),
@@ -57,8 +57,8 @@ class TableUtilsFormatTest {
5757

5858
@Test
5959
def testInsertPartitionsAddRemoveColumns(): Unit = {
60-
val tableName = s"db.test_table_2_$format"
61-
spark.sql("CREATE DATABASE IF NOT EXISTS db")
60+
val tableName = s"db_format.test_table_2_$format"
61+
spark.sql("CREATE DATABASE IF NOT EXISTS db_format")
6262
val columns1 = Array(
6363
StructField("long_field", LongType),
6464
StructField("int_field", IntType),
@@ -92,8 +92,8 @@ class TableUtilsFormatTest {
9292

9393
@Test
9494
def testInsertPartitionsAddModifyColumns(): Unit = {
95-
val tableName = s"db.test_table_3_$format"
96-
spark.sql("CREATE DATABASE IF NOT EXISTS db")
95+
val tableName = s"db_format.test_table_3_$format"
96+
spark.sql("CREATE DATABASE IF NOT EXISTS db_format")
9797
val columns1 = Array(
9898
StructField("long_field", LongType),
9999
StructField("int_field", IntType)

0 commit comments

Comments
 (0)