beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Sumit Chawla (JIRA)" <j...@apache.org>
Subject [jira] [Created] (BEAM-682) Invoker Class should be created in Thread
Date Mon, 26 Sep 2016 23:44:20 GMT
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)

Mime
View raw message