lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[MINOR] Fix typo,'deseralized' corrected to 'deserialized' & 'Kyro' corrected to 'Kryo' (#3846)

Browse Source
This commit is contained in:
董可伦
2021-10-25 21:56:47 +08:00
committed by GitHub
parent 220bf6a7e6
commit 4b5512e685
2 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
hudi-common/src/test/java/org/apache/hudi/common/table/TestHoodieTableMetaClient.java
View File

@@ -59,10 +59,10 @@ public class TestHoodieTableMetaClient extends HoodieCommonTestHarness {
@Test @Test
public void checkSerDe() { public void checkSerDe() {
// check if this object is serialized and de-serialized, we are able to read from the file system // 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); HoodieTestUtils.serializeDeserialize(metaClient, HoodieTableMetaClient.class);
assertNotNull(deseralizedMetaClient); assertNotNull(deserializedMetaClient);
HoodieActiveTimeline commitTimeline = deseralizedMetaClient.getActiveTimeline(); HoodieActiveTimeline commitTimeline = deserializedMetaClient.getActiveTimeline();
HoodieInstant instant = new HoodieInstant(true, HoodieTimeline.COMMIT_ACTION, "1"); HoodieInstant instant = new HoodieInstant(true, HoodieTimeline.COMMIT_ACTION, "1");
commitTimeline.createNewInstant(instant); commitTimeline.createNewInstant(instant);
commitTimeline.saveAsComplete(instant, Option.of("test-detail".getBytes())); commitTimeline.saveAsComplete(instant, Option.of("test-detail".getBytes()));

6
hudi-common/src/test/java/org/apache/hudi/common/testutils/HoodieTestUtils.java
View File

@@ -112,7 +112,7 @@ public class HoodieTestUtils {
} }
public static <T extends Serializable> T serializeDeserialize(T object, Class<T> clazz) { public static <T extends Serializable> T serializeDeserialize(T object, Class<T> clazz) {
// Using Kyro as the default serializer in Spark Jobs // Using Kryo as the default serializer in Spark Jobs
Kryo kryo = new Kryo(); Kryo kryo = new Kryo();
kryo.register(HoodieTableMetaClient.class, new JavaSerializer()); kryo.register(HoodieTableMetaClient.class, new JavaSerializer());
@@ -122,9 +122,9 @@ public class HoodieTestUtils {
output.close(); output.close();
Input input = new Input(new ByteArrayInputStream(baos.toByteArray())); Input input = new Input(new ByteArrayInputStream(baos.toByteArray()));
T deseralizedObject = kryo.readObject(input, clazz); T deserializedObject = kryo.readObject(input, clazz);
input.close(); input.close();
return deseralizedObject; return deserializedObject;
} }
public static List<HoodieWriteStat> generateFakeHoodieWriteStat(int limit) { public static List<HoodieWriteStat> generateFakeHoodieWriteStat(int limit) {