From 4b5512e6857ce8265d048ecbcdb2b8cccb199d2e Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E8=91=A3=E5=8F=AF=E4=BC=A6?= Date: Mon, 25 Oct 2021 21:56:47 +0800 Subject: [PATCH] [MINOR] Fix typo,'deseralized' corrected to 'deserialized' & 'Kyro' corrected to 'Kryo' (#3846) --- .../apache/hudi/common/table/TestHoodieTableMetaClient.java | 6 +++--- .../org/apache/hudi/common/testutils/HoodieTestUtils.java | 6 +++--- 2 files changed, 6 insertions(+), 6 deletions(-) diff --git a/hudi-common/src/test/java/org/apache/hudi/common/table/TestHoodieTableMetaClient.java b/hudi-common/src/test/java/org/apache/hudi/common/table/TestHoodieTableMetaClient.java index 121e173c6..586a45106 100644 --- a/hudi-common/src/test/java/org/apache/hudi/common/table/TestHoodieTableMetaClient.java +++ b/hudi-common/src/test/java/org/apache/hudi/common/table/TestHoodieTableMetaClient.java @@ -59,10 +59,10 @@ public class TestHoodieTableMetaClient extends HoodieCommonTestHarness { @Test public void checkSerDe() { // check if this object is serialized and de-serialized, we are able to read from the file system - HoodieTableMetaClient deseralizedMetaClient = + HoodieTableMetaClient deserializedMetaClient = HoodieTestUtils.serializeDeserialize(metaClient, HoodieTableMetaClient.class); - assertNotNull(deseralizedMetaClient); - HoodieActiveTimeline commitTimeline = deseralizedMetaClient.getActiveTimeline(); + assertNotNull(deserializedMetaClient); + HoodieActiveTimeline commitTimeline = deserializedMetaClient.getActiveTimeline(); HoodieInstant instant = new HoodieInstant(true, HoodieTimeline.COMMIT_ACTION, "1"); commitTimeline.createNewInstant(instant); commitTimeline.saveAsComplete(instant, Option.of("test-detail".getBytes())); diff --git a/hudi-common/src/test/java/org/apache/hudi/common/testutils/HoodieTestUtils.java b/hudi-common/src/test/java/org/apache/hudi/common/testutils/HoodieTestUtils.java index 259d0c250..67b147aa6 100644 --- a/hudi-common/src/test/java/org/apache/hudi/common/testutils/HoodieTestUtils.java +++ b/hudi-common/src/test/java/org/apache/hudi/common/testutils/HoodieTestUtils.java @@ -112,7 +112,7 @@ public class HoodieTestUtils { } public static T serializeDeserialize(T object, Class clazz) { - // Using Kyro as the default serializer in Spark Jobs + // Using Kryo as the default serializer in Spark Jobs Kryo kryo = new Kryo(); kryo.register(HoodieTableMetaClient.class, new JavaSerializer()); @@ -122,9 +122,9 @@ public class HoodieTestUtils { output.close(); Input input = new Input(new ByteArrayInputStream(baos.toByteArray())); - T deseralizedObject = kryo.readObject(input, clazz); + T deserializedObject = kryo.readObject(input, clazz); input.close(); - return deseralizedObject; + return deserializedObject; } public static List generateFakeHoodieWriteStat(int limit) {