Github user HeartSaVioR commented on a diff in the pull request:
https://github.com/apache/storm/pull/2241#discussion_r158195269
--- Diff: storm-client/src/jvm/org/apache/storm/daemon/worker/Worker.java
---
@@ -311,7 +331,7 @@ public void doExecutorHeartbeats() {
.workerHeartbeat(workerState.topologyId,
workerState.assignmentId, (long) workerState.port,
StatsUtil.thriftifyZkWorkerHb(zkHB));
} catch (Exception ex) {
- LOG.error("Worker failed to write heartbeats to ZK or
Pacemaker...will retry", ex);
+ LOG.error("Worker failed to write heartbeats to ZK or
Pacemaker...will retrying", ex);
--- End diff --
nit: Looks like it was correct.
---
