gaoran10 opened a new pull request #6445: Fix avro schema decode error in functions URL: https://github.com/apache/pulsar/pull/6445 Fixes #5503 ### Motivation In functions, it will encounter ```ClassCastException``` when using the Avro schema for topics. ``` Exception in thread "main" java.lang.ClassCastException: org.apache.pulsar.shade.org.apache.avro.generic.GenericData$Record cannot be cast to io.streamnative.KeyValueSchemaTest$Foo2 at io.streamnative.KeyValueSchemaTest.testConsumerByPythonProduce(KeyValueSchemaTest.java:412) at io.streamnative.KeyValueSchemaTest.main(KeyValueSchemaTest.java:305) ``` ### Modifications In functions, when using Avro schema specific the ```ClassLoader``` for ```ReflectDatumReader```.
---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: [email protected] With regards, Apache Git Services
