Aitozi created FLINK-24021: ------------------------------ Summary: Potential job unrecoverable due to Network failure Key: FLINK-24021 URL: https://issues.apache.org/jira/browse/FLINK-24021 Project: Flink Issue Type: Bug Components: Runtime / Coordination Reporter: Aitozi
Now we use zk to do leader election and retrieval for HA. And we register a fatalError handler in leaderElectionService and leaderRetrievalService to let jobManager or taskManager process exit at the time of some unexpected error. But we don't do this at the time of curatorFrameworkClient#start in ZookeeperUtils. This may lead to some unexpected error like : # ZookeeperUtils start curator client, but failed by network loss, this will not throw exception now, because we do not register a error handler. # The network recover when master begin do leader election, so this will success # The leaderRetrieval begin to work by get_data periodically, but this will not be executed , because the curator client start failed in phase 1. So I think we should register a error handler in phase1 , so that we can fail fast. -- This message was sent by Atlassian Jira (v8.3.4#803005)