Format source and use dedicated getClient() method to obtain the clusterClient. Original Pull Request: #297