Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5767#discussion_r177318939
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/program/MiniClusterClient.java
---
@@ -67,7 +61,7 @@
private final ScheduledExecutorService scheduledExecutorService =
Executors.newScheduledThreadPool(4, new
ExecutorThreadFactory("Flink-MiniClusterClient"));
private final ScheduledExecutor scheduledExecutor = new
ScheduledExecutorServiceAdapter(scheduledExecutorService);
--- End diff --
Yes, will remove it.
---
