Hi Max,

The error message shows up in the flink web UI, so I think it must be reaching 
the cluster. 

For the portable runner the error is listed in the docker container output as 
well but I assume that is just receiving the error message from the flink 
cluster.

Thanks,
Jesse

On 6/23/20, 8:11 AM, "Maximilian Michels" <[email protected]> wrote:

    Hey Jesse,

    Could you share the context of the error? Where does it occur? In the
    client code or on the cluster?

    Cheers,
    Max

    On 22.06.20 18:01, Jesse Lord wrote:
    > I am trying to run the wordcount quickstart example on a flink cluster
    > on AWS EMR. Beam version 2.22, Flink 1.10.
    > 
    >  
    > 
    > I get the following error:
    > 
    >  
    > 
    > ERROR:root:java.util.ServiceConfigurationError:
    > com.fasterxml.jackson.databind.Module: Provider
    > com.fasterxml.jackson.module.jaxb.JaxbAnnotationModule not a subtype
    > 
    >  
    > 
    > This happens with both the portable runner (using python SDK) and the
    > classic flink runner using the quickstart maven project.
    > 
    >  
    > 
    > I think this error relates to this issue:
    > 
https://nam05.safelinks.protection.outlook.com/?url=https%3A%2F%2Fissues.apache.org%2Fjira%2Fbrowse%2FBEAM-9239&amp;data=02%7C01%7Cjlord%40vectra.ai%7C1b00ebd9f3e84f55d76708d81787c205%7Ca6cc66bcf41945c2a9c28ff4ab685f2d%7C1%7C0%7C637285219131055724&amp;sdata=GqQ6xx%2Fuowa6DWy%2FCvdDw4IA4C%2FvnM0Yaj6%2Fpqnnric%3D&amp;reserved=0.
 Based on the comments
    > from this issue I tried adjusting parameters for whether flink
    > prioritizes loading child (user) jars or parent (flink) jars in the
    > classpath but it did not resolve the issue.
    > 
    >  
    > 
    > Looking for any suggestions that might help as a workaround and
    > wondering if I should open a new jira issue or only add my comment to
    > the existing issue (which I have already done).
    > 
    >  
    > 
    > Thanks,
    > 
    > Jesse
    > 

Reply via email to