I get an java.lang.ClassNotFoundException: org.apache.flink.api.common.serialization.RuntimeContextInitializationContextAdapters when running my Apache Flink code locally. It works fine when I use a local generator for my DataStream. As soon as I switch to an AWS FlinkKinesisConsumer to get me the DataStream I get the above-mentioned error. Did I miss to add a dependency ? My guess is i has something to do with serialization.
- RuntimeContextInitializationContextAdapters: ClassNotFound... Harald Busch
