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.