Hi, Harald Which version of flink are you referring to?
Best, Weihua On Thu, Jun 30, 2022 at 11:38 AM Harald Busch <ba5...@bnv-bamberg.de> wrote: > 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.