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?
---