I am using Flink Kubernetes Operator.
There were flink jobs running even after SessionJob was deleted. Has anyone every seen it?
I could see an Exception in the SessionJob events but the job was submitted successfully and the older job remained dangling. I had to manually remove it using REST API.
Warning SessionJobException 4m52s Job org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannel$AnnotatedConnectException: Connection refused