Github user srdo commented on a diff in the pull request:

    https://github.com/apache/storm/pull/2587#discussion_r175576651
  
    --- Diff: 
storm-client/src/jvm/org/apache/storm/pacemaker/PacemakerClientPool.java ---
    @@ -54,25 +54,17 @@ public PacemakerClientPool(Map<String, Object> config) {
             }
         }
         
    -    public HBMessage send(HBMessage m) throws PacemakerConnectionException 
{
    -        try {
    +    public HBMessage send(HBMessage m) throws InterruptedException {
                 return getWriteClient().send(m);
    -        } catch (Exception e) {
    -            rotateClients();
    --- End diff --
    
    Thanks, that makes sense. rotateClients looks unused now, does it make 
sense to keep?


---

Reply via email to