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);`
    
    



---

Reply via email to