Skip to content

Instantly share code, notes, and snippets.

@shardnit
Created September 5, 2012 09:10
Show Gist options
  • Save shardnit/3633809 to your computer and use it in GitHub Desktop.
Save shardnit/3633809 to your computer and use it in GitHub Desktop.
Storm Nimbus log
2012-09-05 11:03:07 nimbus [INFO] Received topology submission for tweetindexer with conf {"topology.acker.executors" 1, "topology.kryo.register" nil, "topology.name" "tweetindexer", "storm.id" "tweetindexer-2-1346835787", "topology.max.task.parallelism" 2, "topology.workers" 2}
2012-09-05 11:03:07 nimbus [INFO] Activating tweetindexer: tweetindexer-2-1346835787
2012-09-05 11:03:07 EvenScheduler [INFO] Available slots: (["5f0e55f0-a64f-483f-b56d-2ba7eab18efd" 6700] ["5f0e55f0-a64f-483f-b56d-2ba7eab18efd" 6701] ["5f0e55f0-a64f-483f-b56d-2ba7eab18efd" 6702] ["5f0e55f0-a64f-483f-b56d-2ba7eab18efd" 6703])
2012-09-05 11:03:07 nimbus [INFO] Setting new assignment for topology id tweetindexer-2-1346835787: #backtype.storm.daemon.common.Assignment{:master-code-dir "storm-local/nimbus/stormdist/tweetindexer-2-1346835787", :node->host {"5f0e55f0-a64f-483f-b56d-2ba7eab18efd" "node7.cluster1.skln.es"}, :executor->node+port {[3 3] ["5f0e55f0-a64f-483f-b56d-2ba7eab18efd" 6700], [2 2] ["5f0e55f0-a64f-483f-b56d-2ba7eab18efd" 6701], [1 1] ["5f0e55f0-a64f-483f-b56d-2ba7eab18efd" 6700]}, :executor->start-time-secs {[1 1] 1346835787, [3 3] 1346835787, [2 2] 1346835787}}
2012-09-05 11:05:14 nimbus [INFO] Executor tweetindexer-2-1346835787:[2 2] not alive
2012-09-05 11:05:14 nimbus [INFO] Executor tweetindexer-2-1346835787:[3 3] not alive
2012-09-05 11:05:14 nimbus [INFO] Executor tweetindexer-2-1346835787:[1 1] not alive
2012-09-05 11:05:14 EvenScheduler [INFO] Available slots: (["5f0e55f0-a64f-483f-b56d-2ba7eab18efd" 6702] ["5f0e55f0-a64f-483f-b56d-2ba7eab18efd" 6703])
2012-09-05 11:05:14 nimbus [INFO] Reassigning tweetindexer-2-1346835787 to 2 slots
2012-09-05 11:05:14 nimbus [INFO] Reassign executors: [[3 3] [2 2] [1 1]]
2012-09-05 11:05:14 nimbus [INFO] Setting new assignment for topology id tweetindexer-2-1346835787: #backtype.storm.daemon.common.Assignment{:master-code-dir "storm-local/nimbus/stormdist/tweetindexer-2-1346835787", :node->host {"5f0e55f0-a64f-483f-b56d-2ba7eab18efd" "node7.cluster1.skln.es"}, :executor->node+port {[3 3] ["5f0e55f0-a64f-483f-b56d-2ba7eab18efd" 6702], [2 2] ["5f0e55f0-a64f-483f-b56d-2ba7eab18efd" 6703], [1 1] ["5f0e55f0-a64f-483f-b56d-2ba7eab18efd" 6702]}, :executor->start-time-secs {[1 1] 1346835914, [3 3] 1346835914, [2 2] 1346835914}}
2012-09-05 11:07:14 nimbus [INFO] Executor tweetindexer-2-1346835787:[2 2] not alive
2012-09-05 11:07:14 nimbus [INFO] Executor tweetindexer-2-1346835787:[3 3] not alive
2012-09-05 11:07:14 nimbus [INFO] Executor tweetindexer-2-1346835787:[1 1] not alive
2012-09-05 11:07:14 EvenScheduler [INFO] Available slots: (["5f0e55f0-a64f-483f-b56d-2ba7eab18efd" 6700] ["5f0e55f0-a64f-483f-b56d-2ba7eab18efd" 6701])
2012-09-05 11:07:14 nimbus [INFO] Reassigning tweetindexer-2-1346835787 to 2 slots
2012-09-05 11:07:14 nimbus [INFO] Reassign executors: [[3 3] [2 2] [1 1]]
2012-09-05 11:07:14 nimbus [INFO] Setting new assignment for topology id tweetindexer-2-1346835787: #backtype.storm.daemon.common.Assignment{:master-code-dir "storm-local/nimbus/stormdist/tweetindexer-2-1346835787", :node->host {"5f0e55f0-a64f-483f-b56d-2ba7eab18efd" "node7.cluster1.skln.es"}, :executor->node+port {[3 3] ["5f0e55f0-a64f-483f-b56d-2ba7eab18efd" 6700], [2 2] ["5f0e55f0-a64f-483f-b56d-2ba7eab18efd" 6701], [1 1] ["5f0e55f0-a64f-483f-b56d-2ba7eab18efd" 6700]}, :executor->start-time-secs {[1 1] 1346836034, [3 3] 1346836034, [2 2] 1346836034}}
2012-09-05 11:09:15 nimbus [INFO] Executor tweetindexer-2-1346835787:[2 2] not alive
2012-09-05 11:09:15 nimbus [INFO] Executor tweetindexer-2-1346835787:[3 3] not alive
2012-09-05 11:09:15 nimbus [INFO] Executor tweetindexer-2-1346835787:[1 1] not alive
2012-09-05 11:09:15 EvenScheduler [INFO] Available slots: (["5f0e55f0-a64f-483f-b56d-2ba7eab18efd" 6702] ["5f0e55f0-a64f-483f-b56d-2ba7eab18efd" 6703])
2012-09-05 11:09:15 nimbus [INFO] Reassigning tweetindexer-2-1346835787 to 2 slots
2012-09-05 11:09:15 nimbus [INFO] Reassign executors: [[3 3] [2 2] [1 1]]
2012-09-05 11:09:15 nimbus [INFO] Setting new assignment for topology id tweetindexer-2-1346835787: #backtype.storm.daemon.common.Assignment{:master-code-dir "storm-local/nimbus/stormdist/tweetindexer-2-1346835787", :node->host {"5f0e55f0-a64f-483f-b56d-2ba7eab18efd" "node7.cluster1.skln.es"}, :executor->node+port {[3 3] ["5f0e55f0-a64f-483f-b56d-2ba7eab18efd" 6702], [2 2] ["5f0e55f0-a64f-483f-b56d-2ba7eab18efd" 6703], [1 1] ["5f0e55f0-a64f-483f-b56d-2ba7eab18efd" 6702]}, :executor->start-time-secs {[1 1] 1346836155, [3 3] 1346836155, [2 2] 1346836155}}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment