class ClusterClient {

	public void shutdown() throws Exception {
		synchronized (this) {
			actorSystemLoader.shutdown();

			if (!sharedHaServices && highAvailabilityServices != null) {
				highAvailabilityServices.close();
			}
		}
	}

	public  ClusterClient(Configuration flinkConfig);
	public  ClusterClient(Configuration flinkConfig, HighAvailabilityServices highAvailabilityServices, boolean sharedHaServices);

}