You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by "Sumit Chawla (JIRA)" <ji...@apache.org> on 2016/09/26 23:44:20 UTC
[jira] [Created] (BEAM-682) Invoker Class should be created in
Thread
Sumit Chawla created BEAM-682:
---------------------------------
Summary: Invoker Class should be created in Thread
Key: BEAM-682
URL: https://issues.apache.org/jira/browse/BEAM-682
Project: Beam
Issue Type: Bug
Components: sdk-java-core
Affects Versions: 0.3.0-incubating
Reporter: Sumit Chawla
Assignee: Sumit Chawla
Priority: Critical
As of now the InvokerClass is being loaded in wrong classloader. It should be loaded into Thread.currentThread.getContextClassLoader()
https://github.com/apache/incubator-beam/blob/master/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect/DoFnInvokers.java#L167
{code}
Class<? extends DoFnInvoker<?, ?>> res =
(Class<? extends DoFnInvoker<?, ?>>)
unloaded
.load(DoFnInvokers.class.getClassLoader(), ClassLoadingStrategy.Default.INJECTION)
.getLoaded();
{code}
Fix
{code}
Class<? extends DoFnInvoker<?, ?>> res =
(Class<? extends DoFnInvoker<?, ?>>)
unloaded
.load(Thread.currentThread().getContextClassLoader(),
ClassLoadingStrategy.Default.INJECTION)
.getLoaded();
{code}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)