This is an automated email from the ASF dual-hosted git repository. xushiyan pushed a commit to branch release-feature-rfc46 in repository https://gitbox.apache.org/repos/asf/hudi.git
commit bf4ef73a6bef34edca32c7d878660e402d53e331 Author: Raymond Xu <[email protected]> AuthorDate: Wed Jun 15 14:38:31 2022 +0800 [MINOR] Fix type casting in TestHoodieHFileReaderWriter --- .../java/org/apache/hudi/io/storage/TestHoodieHFileReaderWriter.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/hudi-client/hudi-client-common/src/test/java/org/apache/hudi/io/storage/TestHoodieHFileReaderWriter.java b/hudi-client/hudi-client-common/src/test/java/org/apache/hudi/io/storage/TestHoodieHFileReaderWriter.java index 6fb80c2d85..89e3a7738a 100644 --- a/hudi-client/hudi-client-common/src/test/java/org/apache/hudi/io/storage/TestHoodieHFileReaderWriter.java +++ b/hudi-client/hudi-client-common/src/test/java/org/apache/hudi/io/storage/TestHoodieHFileReaderWriter.java @@ -308,6 +308,7 @@ public class TestHoodieHFileReaderWriter extends TestHoodieReaderWriterBase { hfileReader.getRecordsByKeyPrefixIterator(Arrays.asList("key50", "key1"), avroSchema); recordsByPrefix = StreamSupport.stream(Spliterators.spliteratorUnknownSize(iterator, Spliterator.ORDERED), false) + .map(r -> (GenericRecord)r) .collect(Collectors.toList()); assertEquals(expectedKey50and1s, recordsByPrefix); @@ -318,6 +319,7 @@ public class TestHoodieHFileReaderWriter extends TestHoodieReaderWriterBase { hfileReader.getRecordsByKeyPrefixIterator(Arrays.asList("key50", "key0"), avroSchema); recordsByPrefix = StreamSupport.stream(Spliterators.spliteratorUnknownSize(iterator, Spliterator.ORDERED), false) + .map(r -> (GenericRecord)r) .collect(Collectors.toList()); assertEquals(expectedKey50and0s, recordsByPrefix); @@ -329,6 +331,7 @@ public class TestHoodieHFileReaderWriter extends TestHoodieReaderWriterBase { hfileReader.getRecordsByKeyPrefixIterator(Arrays.asList("key1", "key0"), avroSchema); recordsByPrefix = StreamSupport.stream(Spliterators.spliteratorUnknownSize(iterator, Spliterator.ORDERED), false) + .map(r -> (GenericRecord)r) .collect(Collectors.toList()); Collections.sort(recordsByPrefix, new Comparator<GenericRecord>() { @Override
