Github user Ethanlm commented on a diff in the pull request:
https://github.com/apache/storm/pull/2587#discussion_r175579245
--- 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 --
Yea I think we can delete it. Thanks
---
