Github user kishorvpatil commented on a diff in the pull request: https://github.com/apache/storm/pull/2651#discussion_r188107350 --- Diff: storm-client/src/jvm/org/apache/storm/drpc/ReturnResults.java --- @@ -103,21 +85,32 @@ public void execute(Tuple input) { LOG.error("Failed to return results to DRPC server", tex); _collector.fail(input); } - reconnectClient((DRPCInvocationsClient) client); + client = getDRPCClient(host, port); --- End diff -- This is same as before, if we could not make connection. or reconnect failed in previous case.
---