The cause cannot be that flink-metrics-core is not on the classpath as
in that case you'd get a ClassNotFoundError.
This is a version conflict, either caused by your fat jar bundling an
older version of flink-metrics-core but a newer version of the kafka
connector, or you upgrade your applicat
Flink is running as standalone cluster in High Availability mode, My
application jar is a fat jar which has all the necessary dependencies
included.
I will check once again and verify by adding the flink-metrics-core to the
classpath.
Thanks
Chandu
On Wed, Oct 10, 2018 at 8:38 PM vino yang wrot
Hi Chandu,
What mode does your Flink run in?
In addition, can you check if the flink-metrics-core is included in the
classpath of the Flink runtime environment?
Thanks, vino.
Chandu Kempaiah 于2018年10月11日周四 上午9:51写道：
>
> Hello,
>
> I am have a job that reads messages from kafka, processes them
Hello,
I am have a job that reads messages from kafka, processes them and writes
back to kafka, this jobs works fine on flink 1.3.2. I upgraded cluster to
1.6.1 but now see below error. Has any one faced similar issue?
I have updated all the dependencies to use
1.6.1
org.apache.flink
f
