Repository: storm Updated Branches: refs/heads/master cbe1e372a -> d304dd585
Quick fix: typo in WorkerState class Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/44f51f7e Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/44f51f7e Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/44f51f7e Branch: refs/heads/master Commit: 44f51f7e72f97fbd744e663be9ae68c676797a04 Parents: cbe1e37 Author: Meng Li (Ethan) <[email protected]> Authored: Fri Oct 6 14:53:35 2017 -0500 Committer: GitHub <[email protected]> Committed: Fri Oct 6 14:53:35 2017 -0500 ---------------------------------------------------------------------- .../src/jvm/org/apache/storm/daemon/worker/WorkerState.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/44f51f7e/storm-client/src/jvm/org/apache/storm/daemon/worker/WorkerState.java ---------------------------------------------------------------------- diff --git a/storm-client/src/jvm/org/apache/storm/daemon/worker/WorkerState.java b/storm-client/src/jvm/org/apache/storm/daemon/worker/WorkerState.java index d679ee8..825de4b 100644 --- a/storm-client/src/jvm/org/apache/storm/daemon/worker/WorkerState.java +++ b/storm-client/src/jvm/org/apache/storm/daemon/worker/WorkerState.java @@ -485,7 +485,7 @@ public class WorkerState { refreshActiveTimer.schedule(delaySecs, new Runnable() { @Override public void run() { if (areAllConnectionsReady()) { - LOG.info("All connections are ready for worker {}:{} with id", assignmentId, port, workerId); + LOG.info("All connections are ready for worker {}:{} with id {}", assignmentId, port, workerId); isWorkerActive.set(Boolean.TRUE); } else { refreshActiveTimer.schedule(recurSecs, () -> activateWorkerWhenAllConnectionsReady(), false, 0);
