You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hudi.apache.org by da...@apache.org on 2022/10/15 03:13:07 UTC
[hudi] branch master updated: [HUDI-5030] Fix TestPartialUpdateAvroPayload.testUseLatestRecordMetaValue(#6948)
This is an automated email from the ASF dual-hosted git repository.
danny0405 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
The following commit(s) were added to refs/heads/master by this push:
new e9e2e38435 [HUDI-5030] Fix TestPartialUpdateAvroPayload.testUseLatestRecordMetaValue(#6948)
e9e2e38435 is described below
commit e9e2e384353d426d90a71885791743705bee7707
Author: wangzeyu <ha...@gmail.com>
AuthorDate: Sat Oct 15 11:13:00 2022 +0800
[HUDI-5030] Fix TestPartialUpdateAvroPayload.testUseLatestRecordMetaValue(#6948)
---
.../apache/hudi/common/model/TestPartialUpdateAvroPayload.java | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
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 2172406660..d7e1a6146a 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 class TestPartialUpdateAvroPayload {
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 class TestPartialUpdateAvroPayload {
// 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());
}
}