Use the thread context classloader for loading functions (apache#28)

sijie · Mar 4, 2018 · 13bbbf7 · 13bbbf7
1 parent f026ef8
commit 13bbbf7
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 2 deletions.
diff --git a/pulsar-functions/run-examples.sh b/pulsar-functions/run-examples.sh
@@ -17,4 +17,4 @@
 # under the License.
 #
 
-CLASSPATH=`pwd`/api-examples/target/pulsar-functions-api-examples.jar bin/pulsar-functions functions run --function-config conf/example.yml --sink-topic persistent://sample/standalone/ns1/test_result --source-topic persistent://sample/standalone/ns1/test_src --serde-classname org.apache.pulsar.functions.runtime.container.SimpleStringSerDe --function-classpath `pwd`/api-examples/target/pulsar-functions-api-examples.jar
+bin/pulsar-functions functions run --function-config conf/example.yml --sink-topic persistent://sample/standalone/ns1/test_result --source-topic persistent://sample/standalone/ns1/test_src --serde-classname org.apache.pulsar.functions.runtime.container.SimpleStringSerDe --function-classpath `pwd`/api-examples/target/pulsar-functions-api-examples.jar
diff --git a/...ions/runtime/src/main/java/org/apache/pulsar/functions/runtime/instance/JavaInstance.java b/...ions/runtime/src/main/java/org/apache/pulsar/functions/runtime/instance/JavaInstance.java
@@ -59,7 +59,10 @@ public class JavaInstance {
     public static Object createObject(String userClassName) {
         Object object;
         try {
-            Class<?> clazz = Class.forName(userClassName);
+            Class<?> clazz = Class.forName(
+                userClassName,
+                true,
+                Thread.currentThread().getContextClassLoader());
             object = clazz.newInstance();
         } catch (ClassNotFoundException ex) {
             throw new RuntimeException(ex + " User class must be in class path.");