diff --git a/hudi-common/src/test/java/org/apache/hudi/common/model/TestPartialUpdateAvroPayload.java b/hudi-common/src/test/java/org/apache/hudi/common/model/TestPartialUpdateAvroPayload.java index 217240666094d..d7e1a6146ad31 100644 --- a/hudi-common/src/test/java/org/apache/hudi/common/model/TestPartialUpdateAvroPayload.java +++ b/hudi-common/src/test/java/org/apache/hudi/common/model/TestPartialUpdateAvroPayload.java @@ -185,8 +185,8 @@ public void testUseLatestRecordMetaValue() throws IOException { record1.put("child", Arrays.asList("A")); GenericRecord record2 = new GenericData.Record(schema); - record1.put("_hoodie_commit_time", "20220915000000001"); - record1.put("_hoodie_commit_seqno", "20220915000000001_2_000"); + record2.put("_hoodie_commit_time", "20220915000000001"); + record2.put("_hoodie_commit_seqno", "20220915000000001_2_000"); record2.put("id", "1"); record2.put("partition", "partition1"); record2.put("ts", 1L); @@ -204,7 +204,7 @@ public void testUseLatestRecordMetaValue() throws IOException { // let payload2 as the latest one, then should use payload2's meta field's value as the result GenericRecord mergedRecord2 = (GenericRecord) payload2.preCombine(payload1, schema, properties).getInsertValue(schema, properties).get(); - assertEquals(mergedRecord2.get("_hoodie_commit_time").toString(), "20220915000000001"); - assertEquals(mergedRecord2.get("_hoodie_commit_seqno").toString(), "20220915000000001_2_000"); + assertEquals(mergedRecord2.get("_hoodie_commit_time").toString(), record2.get("_hoodie_commit_time").toString()); + assertEquals(mergedRecord2.get("_hoodie_commit_seqno").toString(), record2.get("_hoodie_commit_seqno").toString()); } }