Yangze Guo created FLINK-33053: ---------------------------------- Summary: Watcher leak in Zookeeper HA mode Key: FLINK-33053 URL: https://issues.apache.org/jira/browse/FLINK-33053 Project: Flink Issue Type: Bug Components: Runtime / Coordination Affects Versions: 1.17.1, 1.17.0 Reporter: Yangze Guo
We observe a watcher leak in our OLAP stress test when enabling Zookeeper HA mode. TM's watches on the leader of JobMaster has not been stopped after job finished. Here is how we re-produce this issue: - Start a session cluster and enable Zookeeper HA mode. - Continuously and concurrently submit short queries, e.g. WordCount to the cluster. - `echo -n wchp | nc {zk host} {zk port}` to get current watches. We can see a lot of watches on ~/flink/{cluster_name}/leader/{job_id}/connection_info~. -- This message was sent by Atlassian Jira (v8.20.10#820010)