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://issues.apache.org/jira/browse/BEAM-9239. 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