Hi Clayton,
Could you also help provide the topology of the job?
Also, if convenient could you also have a look at
the back-pressure status of each node, we could
then locate which node are getting slowly and might
cause the lag.
Best,
Yun
I have a Flink job that has been running with Flink 1.14.4 perfectly for a
few months.
I tried upgrading to Flink 1.15.0. There are no error messages or
exceptions, it runs perfectly fine for several hours, but after a few hours
the Flink app starts to lag in processing an input Kafka topic. I can
