zhang-yue1 opened a new issue, #13500: URL: https://github.com/apache/hudi/issues/13500
Describe the problem you faced I’m using Hudi 0.12.1 together with Flink (DataStream API) and Hive 3.x. I write data from my Flink job into a Hudi table with Hive-sync enabled. The Flink job completes successfully and the table appears in the Hive metastore, but when I run: SELECT * FROM my_hudi_table LIMIT 10; or SELECT * FROM my_hudi_table where id = '' ; Hive throws the following error: Caused by: org.apache.hudi.com.esotericsoftware.kryo.KryoException: Encountered unregistered class ID: 14 at org.apache.hudi.com.esotericsoftware.kryo.util.DefaultClassResolver.readClass(DefaultClassResolver.java:137) at org.apache.hudi.com.esotericsoftware.kryo.Kryo.readClass(Kryo.java:693) at org.apache.hudi.com.esotericsoftware.kryo.serializers.DefaultArraySerializers$ObjectArraySerializer.read(DefaultArraySerializers.java:388) at org.apache.hudi.com.esotericsoftware.kryo.serializers.DefaultArraySerializers$ObjectArraySerializer.read(DefaultArraySerializers.java:302) at org.apache.hudi.com.esotericsoftware.kryo.Kryo.readClassAndObject(Kryo.java:813) at org.apache.hudi.common.util.SerializationUtils$KryoSerializerInstance.deserialize(SerializationUtils.java:104) at org.apache.hudi.common.util.SerializationUtils.deserialize(SerializationUtils.java:78) at org.apache.hudi.common.table.log.block.HoodieDeleteBlock.deserialize(HoodieDeleteBlock.java:118) at org.apache.hudi.common.table.log.block.HoodieDeleteBlock.getRecordsToDelete(HoodieDeleteBlock.java:96) at org.apache.hudi.common.table.log.AbstractHoodieLogRecordReader.processQueuedBlocksForInstant(AbstractHoodieLogRecordReader.java:473) at org.apache.hudi.common.table.log.AbstractHoodieLogRecordReader.scanInternal(AbstractHoodieLogRecordReader.java:343) ... 38 more -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
