[FLINK-7432] Unclosed HighAvailabilityServices instance in QueryableStateClient

• Type: Bug
• Status: Closed
• Priority: Minor
• Resolution: Fixed
• Component/s: Runtime / Queryable State
• Assignee: Kostas Kloudas
• Reporter: Ted Yu
• Created: 11/Aug/17 16:27
• Updated: 17/Nov/17 10:29
• Resolved: 17/Nov/17 10:29

Description

  public QueryableStateClient(Configuration config) throws Exception {
    this(config, HighAvailabilityServicesUtils.createHighAvailabilityServices(
        config, Executors.directExecutor(), HighAvailabilityServicesUtils.AddressResolution.TRY_ADDRESS_RESOLUTION));

The HighAvailabilityServices instance is only used for calling getJobManagerLeaderRetriever().

The instance should be closed upon leaving QueryableStateClient ctor.