Hi Flink experts! When a streaming job with Zookeeper-HA enabled gets cancelled all the job-related Zookeeper nodes are not removed. Is there a reason behind that? I noticed that Zookeeper paths are created of type "Container Node" (an Ephemeral node that can have nested nodes) and fall back to Persistent node type in case Zookeeper doesn't support this sort of nodes. But anyway, it is worth removing the job Zookeeper node when a job is cancelled, isn't it?
Thank you in advance! Kind Regards, Mike Pryakhin
smime.p7s
Description: S/MIME cryptographic signature
