Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5312#discussion_r162414419 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/leaderelection/ZooKeeperLeaderElectionService.java --- @@ -412,4 +413,11 @@ protected void handleStateChange(ConnectionState newState) { public void unhandledError(String message, Throwable e) { leaderContender.handleError(new FlinkException("Unhandled error in ZooKeeperLeaderElectionService: " + message, e)); } + + @Override + public String toString() { --- End diff -- Added because the instance logs itself: `LOG.info("Starting ZooKeeperLeaderElectionService {}.", this);`
---