From 44f51f7e72f97fbd744e663be9ae68c676797a04 Mon Sep 17 00:00:00 2001
From: "Meng Li (Ethan)" <ethanopensource@gmail.com>
Date: Fri, 6 Oct 2017 14:53:35 -0500
Subject: [PATCH] Quick fix: typo in WorkerState class

---
 .../src/jvm/org/apache/storm/daemon/worker/WorkerState.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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 d679ee8aa02..825de4b3a95 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 void activateWorkerWhenAllConnectionsReady() {
         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);