Use Function class loader to resolve function types (#1699)

apache · May 1, 2018 · fd576ae · fd576ae
1 parent 600b55d
commit fd576ae
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/source/PulsarSource.java b/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/source/PulsarSource.java
@@ -128,7 +128,7 @@ public void close() throws Exception {
 
     private void setupSerde() throws ClassNotFoundException {
 
-        Class<?> typeArg = Class.forName(this.pulsarConfig.getTypeClassName());
+        Class<?> typeArg = Thread.currentThread().getContextClassLoader().loadClass(this.pulsarConfig.getTypeClassName());
         if (Void.class.equals(typeArg)) {
             throw new RuntimeException("Input type of Pulsar Function cannot be Void");
         }