You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by sr...@apache.org on 2017/10/07 20:30:43 UTC
[1/2] storm git commit: Quick fix: typo in WorkerState class
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) <et...@gmail.com>
Authored: Fri Oct 6 14:53:35 2017 -0500
Committer: GitHub <no...@github.com>
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);
[2/2] storm git commit: Merge branch 'patch-1' of
https://github.com/Ethanlm/storm into asfgit-master
Posted by sr...@apache.org.
Merge branch 'patch-1' of https://github.com/Ethanlm/storm into asfgit-master
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/d304dd58
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/d304dd58
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/d304dd58
Branch: refs/heads/master
Commit: d304dd585239f74b75540cc5f7129f852f822fd8
Parents: cbe1e37 44f51f7
Author: Stig Rohde Døssing <sr...@apache.org>
Authored: Sat Oct 7 22:29:22 2017 +0200
Committer: Stig Rohde Døssing <sr...@apache.org>
Committed: Sat Oct 7 22:29:22 2017 +0200
----------------------------------------------------------------------
.../src/jvm/org/apache/storm/daemon/worker/WorkerState.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------