You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@flink.apache.org by Harald Busch <ba...@bnv-bamberg.de> on 2022/06/30 03:37:46 UTC

RuntimeContextInitializationContextAdapters: ClassNotFoundException

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.

Re: RuntimeContextInitializationContextAdapters: ClassNotFoundException

Posted by Martijn Visser <ma...@apache.org>.
Hi Harald,

Are you using Maven? Do you use IntelliJ? And have you followed the project
configuration page, with regards to setting dependencies as <provided> ? [1]

Best regards,

Martijn

[1]
https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/dev/configuration/maven/#importing-the-project-into-your-ide

Op do 30 jun. 2022 om 15:47 schreef Weihua Hu <hu...@gmail.com>:

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

Re: RuntimeContextInitializationContextAdapters: ClassNotFoundException

Posted by Weihua Hu <hu...@gmail.com>.
Hi, Harald

Which version of flink are you referring to?

Best,
Weihua


On Thu, Jun 30, 2022 at 11:38 AM Harald Busch <ba...@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.