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.

Reply via email to