Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5595#discussion_r171209982 --- Diff: flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/MiniClusterResource.java --- @@ -75,6 +82,10 @@ public MiniClusterResource( this.miniClusterType = Preconditions.checkNotNull(miniClusterType); } + public ClusterClient getClusterClient() { --- End diff -- fixing
---