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) {