Awsmsniper commented on PR #22501:
URL: https://github.com/apache/pulsar/pull/22501#issuecomment-2055610103
> > #20115 fixes the classloader in TopicSchema, but for Kubernetes Runtime,
the classloader may be different from the other runtimes. Which caused the
SerDe to fail to init in Kubernetes Runtime.
>
> @freeznet A question about the description: Regarding "but for Kubernetes
Runtime, the classloader may be different from the other runtimes".
>
> * Is it "may be different" meaning that sometimes it succeeds and
sometimes fails?
>
> * or do you mean to say that it is always different and always fails in
Kubernetes Runtime?
I'm not sure if @freeznet he has this issue every time on Kubernetes, but I
have encountered it when using the extension SDK to connect to Redis cluster. I
am currently unable to use functions on Kubernetes to complete my requirements.
```
2024-04-15T06:18:32,716+0000 [public/default/demo-function-las-auth-0] ERROR
org.apache.pulsar.functions.instance.JavaInstanceRunnable - Sink open produced
uncaught exception:
java.lang.ClassNotFoundException: com.alibaba.fastjson2.JSONObject
at java.net.URLClassLoader.findClass(URLClassLoader.java:445) ~[?:?]
at java.lang.ClassLoader.loadClass(ClassLoader.java:592) ~[?:?]
at java.lang.ClassLoader.loadClass(ClassLoader.java:525) ~[?:?]
at
org.apache.pulsar.common.util.Reflections.loadClass(Reflections.java:310)
~[io.streamnative-pulsar-common-3.2.1.2.jar:3.2.1.2]
at
org.apache.pulsar.functions.sink.PulsarSink.initializeSchema(PulsarSink.java:437)
~[io.streamnative-pulsar-functions-instance-3.2.1.2.jar:3.2.1.2]
at
org.apache.pulsar.functions.sink.PulsarSink.open(PulsarSink.java:362)
~[io.streamnative-pulsar-functions-instance-3.2.1.2.jar:3.2.1.2]
at
org.apache.pulsar.functions.instance.JavaInstanceRunnable.setupOutput(JavaInstanceRunnable.java:1070)
~[io.streamnative-pulsar-functions-instance-3.2.1.2.jar:?]
at
org.apache.pulsar.functions.instance.JavaInstanceRunnable.setup(JavaInstanceRunnable.java:261)
~[io.streamnative-pulsar-functions-instance-3.2.1.2.jar:?]
at
org.apache.pulsar.functions.instance.JavaInstanceRunnable.run(JavaInstanceRunnable.java:305)
~[io.streamnative-pulsar-functions-instance-3.2.1.2.jar:?]
at java.lang.Thread.run(Thread.java:840) ~[?:?]
2024-04-15T06:18:32,725+0000 [public/default/awifi-function-las-auth-0]
ERROR org.apache.pulsar.functions.instance.JavaInstanceRunnable -
[public/default/demo-function-las-auth:0] Uncaught exception in Java Instance
java.lang.ClassNotFoundException: com.alibaba.fastjson2.JSONObject
at java.net.URLClassLoader.findClass(URLClassLoader.java:445) ~[?:?]
at java.lang.ClassLoader.loadClass(ClassLoader.java:592) ~[?:?]
at java.lang.ClassLoader.loadClass(ClassLoader.java:525) ~[?:?]
at
org.apache.pulsar.common.util.Reflections.loadClass(Reflections.java:310)
~[io.streamnative-pulsar-common-3.2.1.2.jar:3.2.1.2]
at
org.apache.pulsar.functions.sink.PulsarSink.initializeSchema(PulsarSink.java:437)
~[io.streamnative-pulsar-functions-instance-3.2.1.2.jar:3.2.1.2]
at
org.apache.pulsar.functions.sink.PulsarSink.open(PulsarSink.java:362)
~[io.streamnative-pulsar-functions-instance-3.2.1.2.jar:3.2.1.2]
at
org.apache.pulsar.functions.instance.JavaInstanceRunnable.setupOutput(JavaInstanceRunnable.java:1070)
~[io.streamnative-pulsar-functions-instance-3.2.1.2.jar:?]
at
org.apache.pulsar.functions.instance.JavaInstanceRunnable.setup(JavaInstanceRunnable.java:261)
~[io.streamnative-pulsar-functions-instance-3.2.1.2.jar:?]
at
org.apache.pulsar.functions.instance.JavaInstanceRunnable.run(JavaInstanceRunnable.java:305)
~[io.streamnative-pulsar-functions-instance-3.2.1.2.jar:?]
at java.lang.Thread.run(Thread.java:840) ~[?:?]
```
--
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]
