code: private void notifyOfNewResourceManagerLeader(String newLeaderAddress, ResourceManagerId newResourceManagerId) {
  		resourceManagerAddress = createResourceManagerAddress(newLeaderAddress, newResourceManagerId);
  		reconnectToResourceManager(new FlinkException(String.format("ResourceManager leader changed to new address %s", resourceManagerAddress)));
  	}
docs: ------------------------------------------------------------------------