class KubernetesClusterDescriptor implements ClusterDescriptor<String> {

	@Override
	public void killCluster(String clusterId) throws FlinkException {
		try {
			client.stopAndCleanupCluster(clusterId);
		} catch (Exception e) {
			client.handleException(e);
			throw new FlinkException("Could not kill Kubernetes cluster " + clusterId);
		}
	}

	public  KubernetesClusterDescriptor(Configuration flinkConfig, FlinkKubeClient client);

}