[proxima-direct-core] set classloader to thread pool

Author: je-ik

core/src/main/java/cz/o2/proxima/core/util/Classpath.java

@@ -60,7 +60,10 @@ public static <T> Class<? extends T> findClass(String name, Class<T> superClass)
     }
     throw new RuntimeException(
         String.format(
-            "Cannot find class %s using %s", name, Thread.currentThread().getContextClassLoader()));
+            "Cannot find class %s using %s in thread %s",
+            name,
+            Thread.currentThread().getContextClassLoader(),
+            Thread.currentThread().getName()));
   }
 
   @SuppressWarnings("unchecked")

direct/core/src/main/java/cz/o2/proxima/direct/core/DirectDataOperator.java

@@ -93,6 +93,7 @@ private static Factory<ExecutorService> createExecutorFactory() {
                         "Error running task in thread {}, bailing out...", thr.getName(), exc);
                     Runtime.getRuntime().exit(1);
                   });
+              t.setContextClassLoader(DirectDataOperator.class.getClassLoader());
               return t;
             });
   }