of support, have you tried with a
>>> newer version of Flink?
>>> ------
>>> *From:* Sachin Mittal
>>> *Sent:* Tuesday, March 12, 2024 14:48
>>> *To:* user@flink.apache.org
>>> *Subject:* Facing ClassNotFoundExceptio
have you tried with a
>> newer version of Flink?
>> --
>> *From:* Sachin Mittal
>> *Sent:* Tuesday, March 12, 2024 14:48
>> *To:* user@flink.apache.org
>> *Subject:* Facing ClassNotFoundException:
>> org.apache.flink.api.common.Exec
Hi Hang,
Once I exclude file-core from the fat jar I get this error:
I believe org.apache.flink.util.OutputTag is part of flink-core itself.
Exception in thread "main" java.lang.NoClassDefFoundError:
org/apache/flink/util/OutputTag
at java.base/java.lang.Class.forName0(Native Method)
Ok. Actually it’s version 1.18. I will try to remove flink-core from the
fat jar.
On Tue, 12 Mar 2024 at 1:51 PM, Hang Ruan wrote:
> Hi, Sachin.
>
> This error occurs when there is class conflict. There is no need to
> package flink-core in your own jar. It is already contained in flink-dist.
>
ion of Flink?
> --
> *From:* Sachin Mittal
> *Sent:* Tuesday, March 12, 2024 14:48
> *To:* user@flink.apache.org
> *Subject:* Facing ClassNotFoundException:
> org.apache.flink.api.common.ExecutionConfig on EMR
>
> Hi,
> We have installed a
Hi, Sachin.
This error occurs when there is class conflict. There is no need to package
flink-core in your own jar. It is already contained in flink-dist.
And Flink version 1.8 is too old. It is better to update your flink version.
Best,
Hang
Sachin Mittal 于2024年3月12日周二 16:04写道：
> Hi,
> We h
:
org.apache.flink.api.common.ExecutionConfig on EMR
Hi,
We have installed a flink cluster version 1.8.0 on AWS EMR.
However when we submit a job we get the following error:
(Do note that when we submit the same job on a local instance of Flink 1.8.1 it
is working fine.
The fat jar we submit has all the flink dependencies from
Hi,
We have installed a flink cluster version 1.8.0 on AWS EMR.
However when we submit a job we get the following error:
(Do note that when we submit the same job on a local instance of Flink
1.8.1 it is working fine.
The fat jar we submit has all the flink dependencies from 1.8.0 including
the cl
