Hi Kostas, ClusterClient class is not our custom class it is in org.apache.flink.client.program package. i can see defination of ClusterClient has changed from 1.9.2 to 1.11.1
https://ci.apache.org/projects/flink/flink-docs-release-1.9/api/java/org/apache/flink/client/program/ClusterClient.html <https://ci.apache.org/projects/flink/flink-docs-release-1.9/api/java/org/apache/flink/client/program/ClusterClient.html> https://ci.apache.org/projects/flink/flink-docs-release-1.11/api/java/org/apache/flink/client/program/ClusterClient.html <https://ci.apache.org/projects/flink/flink-docs-release-1.11/api/java/org/apache/flink/client/program/ClusterClient.html> Thanks, -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/