Skip to content

Commit 8b4d73c

Browse files
committed
fix test to omit hoodie.table.create.schema
1 parent eb4b90e commit 8b4d73c

1 file changed

Lines changed: 3 additions & 2 deletions

File tree

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

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -117,7 +117,7 @@ class TestRepairsProcedure extends HoodieSparkProcedureTestBase {
117117
|[hoodie.datasource.write.hive_style_partitioning,true,null]
118118
|[hoodie.datasource.write.partitionpath.urlencode,false,null]
119119
|[hoodie.table.checksum,,]
120-
|[hoodie.table.create.schema,{"type":"record","name":"h0_record","namespace":"hoodie.h0","fields":[{"name":"_hoodie_commit_time","type":["string","null"]},{"name":"_hoodie_commit_seqno","type":["string","null"]},{"name":"_hoodie_record_key","type":["string","null"]},{"name":"_hoodie_partition_path","type":["string","null"]},{"name":"_hoodie_file_name","type":["string","null"]},{"name":"id","type":["int","null"]},{"name":"name","type":["string","null"]},{"name":"price","type":["double","null"]},{"name":"ts","type":["long","null"]}]},null]
120+
|[hoodie.table.create.schema,,]
121121
|[hoodie.table.keygenerator.class,org.apache.hudi.keygen.NonpartitionedKeyGenerator,null]
122122
|[hoodie.table.name,h0,test_table]
123123
|[hoodie.table.precombine.field,ts,null]
@@ -129,8 +129,9 @@ class TestRepairsProcedure extends HoodieSparkProcedureTestBase {
129129
val actual = spark.sql(s"""call repair_overwrite_hoodie_props(table => '$tableName', new_props_file_path => '${newProps.getPath}')""")
130130
.collect()
131131
.map {
132-
// omit the values for these properties to be future-proof
132+
// omit these properties with variant values
133133
case row if row.getString(0).equals("hoodie.table.checksum") => "[hoodie.table.checksum,,]"
134+
case row if row.getString(0).equals("hoodie.table.create.schema") => "[hoodie.table.create.schema,,]"
134135
case row if row.getString(0).equals("hoodie.table.version") => "[hoodie.table.version,,]"
135136
case row if row.getString(0).equals("hoodie.timeline.layout.version") => "[hoodie.timeline.layout.version,,]"
136137
case o => o.toString()

0 commit comments

Comments
 (0)