Skip to content

Commit f9bceee

Browse files
author
xiaoxingstack
committed
fix legacy test code not follow spark infer keygen clazz way issue
1 parent 8154663 commit f9bceee

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/TestCreateTable.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,7 @@ import org.apache.spark.sql.SaveMode
2828
import org.apache.spark.sql.catalyst.TableIdentifier
2929
import org.apache.spark.sql.catalyst.catalog.CatalogTableType
3030
import org.apache.spark.sql.types._
31-
import org.junit.jupiter.api.Assertions.{assertFalse, assertTrue}
31+
import org.junit.jupiter.api.Assertions.assertFalse
3232

3333
import scala.collection.JavaConverters._
3434

@@ -136,7 +136,7 @@ class TestCreateTable extends HoodieSparkSqlTestBase {
136136
assertResult("dt")(tableConfig(HoodieTableConfig.PARTITION_FIELDS.key))
137137
assertResult("id")(tableConfig(HoodieTableConfig.RECORDKEY_FIELDS.key))
138138
assertResult("ts")(tableConfig(HoodieTableConfig.PRECOMBINE_FIELD.key))
139-
assertResult(classOf[ComplexKeyGenerator].getCanonicalName)(tableConfig(HoodieTableConfig.KEY_GENERATOR_CLASS_NAME.key))
139+
assertResult(classOf[SimpleKeyGenerator].getCanonicalName)(tableConfig(HoodieTableConfig.KEY_GENERATOR_CLASS_NAME.key))
140140
assertResult("default")(tableConfig(HoodieTableConfig.DATABASE_NAME.key()))
141141
assertResult(tableName)(tableConfig(HoodieTableConfig.NAME.key()))
142142
assertFalse(tableConfig.contains(OPERATION.key()))

0 commit comments

Comments
 (0)