geonyeongkim opened a new issue, #8164: URL: https://github.com/apache/hudi/issues/8164
**Describe the problem you faced** Hello. I'm going to get the log data in json format from kafka and create an app that loads it into the hudi table using the hudi stream api. Operation has been set to BULK_INSERT to load log data. However, if you set it to BULK_INSERT, the casting problem will occur as follows. `KryoSerializer cannot be cast to class org.apache.flink.table.runtime.typeutils.AbstractRowDataSerializer` --- This occurs during the opening of the Sort Operator class. - [SortOperator](https://github.com/apache/hudi/blob/25c2f5949384def4b22d1a77f3fe76cc0d493f06/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bulk/sort/SortOperator.java#L72) Flink uses Kryo as the default Serializer. How can I use Sort Operator to perform BULK_INSERT? **Environment Description** * Hudi version : 0.12.2 * Flink version : 1.15.1 -- 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]
