wrote:
> 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,
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
