Ted Yu created FLINK-7432: ----------------------------- Summary: Unclosed HighAvailabilityServices instance in QueryableStateClient Key: FLINK-7432 URL: https://issues.apache.org/jira/browse/FLINK-7432 Project: Flink Issue Type: Bug Reporter: Ted Yu Priority: Minor
{code} public QueryableStateClient(Configuration config) throws Exception { this(config, HighAvailabilityServicesUtils.createHighAvailabilityServices( config, Executors.directExecutor(), HighAvailabilityServicesUtils.AddressResolution.TRY_ADDRESS_RESOLUTION)); {code} The HighAvailabilityServices instance is only used for calling getJobManagerLeaderRetriever(). The instance should be closed upon leaving QueryableStateClient ctor. -- This message was sent by Atlassian JIRA (v6.4.14#64029)