sijie commented on issue #5350: Pulsar can't load the customized SerDe URL: https://github.com/apache/pulsar/issues/5350#issuecomment-540154470 The problem is in PulsarSink.java. We don't use the right class loader to load the SerDe class. https://github.com/apache/pulsar/blob/6ff1bbae0fe230eb72d62574d7685a745f884416/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/sink/PulsarSink.java#L330 The fix should be straightforward to use `functionClassLoader` to load the SerDe class.
---------------------------------------------------------------- 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: us...@infra.apache.org With regards, Apache Git Services
