Hi,
I have deployed my jar on nimbus using the storm submitter.
1531 [main] INFO backtype.storm.StormSubmitter - Jar not uploaded to
master yet. Submitting jar...
2063 [main] INFO backtype.storm.StormSubmitter - Uploading topology jar
storm-sample-0.0.1-SNAPSHOT.jar to assigned location:
/mnt/storm/nimbus/inbox/stormjar-546b5056-9fe3-4250-a149-f2c89b8e99aa.jar
4203 [main] INFO backtype.storm.StormSubmitter - Successfully uploaded
topology jar to assigned location:
/mnt/storm/nimbus/inbox/stormjar-546b5056-9fe3-4250-a149-f2c89b8e99aa.jar
4203 [main] INFO backtype.storm.StormSubmitter - Submitting topology
<topology> in distributed mode with conf
{"topology.fall.back.on.java.serialization":true,"topology.workers":1,"topology.debug":false,"topology.max.spout.pending":5000}
4844 [main] INFO backtype.storm.StormSubmitter - Finished submitting
topology: <topology>
In Nimbus.log
I see the following thing keep on repeating
2014-08-11 05:54:51 b.s.d.nimbus [INFO] Received topology submission for
<topology> with conf {"storm.id" "<topology>-1-1407736491",
"topology.fall.back.on.java.serialization" true, "topology.acker.executors"
nil, "topology.kryo.decorators" (), "topology.name" "<topology>",
"topology.max.spout.pending" 5000, "topology.debug" false,
"topology.kryo.register" nil, "topology.workers" 1,
"topology.max.task.parallelism" nil}
2014-08-11 05:54:51 b.s.d.nimbus [INFO] Activating <topology>:
<topology>-1-1407736491
2014-08-11 05:54:51 b.s.s.EvenScheduler [INFO] Available slots:
(["0d962439-dfeb-416a-8964-6233be5d3685" 6703]
["0d962439-dfeb-416a-8964-6233be5d3685" 6702]
["0d962439-dfeb-416a-8964-6233be5d3685" 6701]
["0d962439-dfeb-416a-8964-6233be5d3685" 6700]
["d8640f36-3533-4445-81ec-f715e7a6fb56" 6703]
["d8640f36-3533-4445-81ec-f715e7a6fb56" 6702]
["d8640f36-3533-4445-81ec-f715e7a6fb56" 6701]
["d8640f36-3533-4445-81ec-f715e7a6fb56" 6700])
2014-08-11 05:54:51 b.s.d.nimbus [INFO] Setting new assignment for topology
id <topology>-1-1407736491:
#backtype.storm.daemon.common.Assignment{:master-code-dir
"/mnt/storm/nimbus/stormdist/<topology>-1-1407736491", :node->host
{"0d962439-dfeb-416a-8964-6233be5d3685" "ip-10-110-239-49.ec2.internal"},
:executor->node+port {[2 2] ["0d962439-dfeb-416a-8964-6233be5d3685" 6703],
[3 3] ["0d962439-dfeb-416a-8964-6233be5d3685" 6703], [4 4]
["0d962439-dfeb-416a-8964-6233be5d3685" 6703], [5 5]
["0d962439-dfeb-416a-8964-6233be5d3685" 6703], [6 6]
["0d962439-dfeb-416a-8964-6233be5d3685" 6703], [7 7]
["0d962439-dfeb-416a-8964-6233be5d3685" 6703], [8 8]
["0d962439-dfeb-416a-8964-6233be5d3685" 6703], [9 9]
["0d962439-dfeb-416a-8964-6233be5d3685" 6703], [10 10]
["0d962439-dfeb-416a-8964-6233be5d3685" 6703], [11 11]
["0d962439-dfeb-416a-8964-6233be5d3685" 6703], [12 12]
["0d962439-dfeb-416a-8964-6233be5d3685" 6703], [13 13]
["0d962439-dfeb-416a-8964-6233be5d3685" 6703], [14 14]
["0d962439-dfeb-416a-8964-6233be5d3685" 6703], [15 15]
["0d962439-dfeb-416a-8964-6233be5d3685" 6703], [16 16]
["0d962439-dfeb-416a-8964-6233be5d3685" 6703], [17 17]
["0d962439-dfeb-416a-8964-6233be5d3685" 6703], [1 1]
["0d962439-dfeb-416a-8964-6233be5d3685" 6703]}, :executor->start-time-secs
{[2 2] 1407736491, [3 3] 1407736491, [4 4] 1407736491, [5 5] 1407736491, [6
6] 1407736491, [7 7] 1407736491, [8 8] 1407736491, [9 9] 1407736491, [10
10] 1407736491, [11 11] 1407736491, [12 12] 1407736491, [13 13] 1407736491,
[14 14] 1407736491, [15 15] 1407736491, [16 16] 1407736491, [17 17]
1407736491, [1 1] 1407736491}}
2014-08-11 05:56:51 b.s.d.nimbus [INFO] Executor <topology>-1-1407736491:[2
2] not alive
2014-08-11 05:56:51 b.s.d.nimbus [INFO] Executor <topology>-1-1407736491:[3
3] not alive
2014-08-11 05:56:51 b.s.d.nimbus [INFO] Executor <topology>-1-1407736491:[4
4] not alive
2014-08-11 05:56:51 b.s.d.nimbus [INFO] Executor <topology>-1-1407736491:[5
5] not alive
2014-08-11 05:56:51 b.s.d.nimbus [INFO] Executor <topology>-1-1407736491:[6
6] not alive
2014-08-11 05:56:51 b.s.d.nimbus [INFO] Executor <topology>-1-1407736491:[7
7] not alive
2014-08-11 05:56:51 b.s.d.nimbus [INFO] Executor <topology>-1-1407736491:[8
8] not alive
2014-08-11 05:56:51 b.s.d.nimbus [INFO] Executor <topology>-1-1407736491:[9
9] not alive
2014-08-11 05:56:51 b.s.d.nimbus [INFO] Executor
<topology>-1-1407736491:[10 10] not alive
2014-08-11 05:56:51 b.s.d.nimbus [INFO] Executor
<topology>-1-1407736491:[11 11] not alive
2014-08-11 05:56:51 b.s.d.nimbus [INFO] Executor
<topology>-1-1407736491:[12 12] not alive
2014-08-11 05:56:51 b.s.d.nimbus [INFO] Executor
<topology>-1-1407736491:[13 13] not alive
2014-08-11 05:56:51 b.s.d.nimbus [INFO] Executor
<topology>-1-1407736491:[14 14] not alive
2014-08-11 05:56:51 b.s.d.nimbus [INFO] Executor
<topology>-1-1407736491:[15 15] not alive
2014-08-11 05:56:51 b.s.d.nimbus [INFO] Executor
<topology>-1-1407736491:[16 16] not alive
2014-08-11 05:56:51 b.s.d.nimbus [INFO] Executor
<topology>-1-1407736491:[17 17] not alive
2014-08-11 05:56:51 b.s.d.nimbus [INFO] Executor <topology>-1-1407736491:[1
1] not alive
2014-08-11 05:56:51 b.s.s.EvenScheduler [INFO] Available slots:
(["0d962439-dfeb-416a-8964-6233be5d3685" 6702]
["0d962439-dfeb-416a-8964-6233be5d3685" 6701]
["0d962439-dfeb-416a-8964-6233be5d3685" 6700]
["d8640f36-3533-4445-81ec-f715e7a6fb56" 6703]
["d8640f36-3533-4445-81ec-f715e7a6fb56" 6702]
["d8640f36-3533-4445-81ec-f715e7a6fb56" 6701]
["d8640f36-3533-4445-81ec-f715e7a6fb56" 6700])
2014-08-11 05:56:51 b.s.d.nimbus [INFO] Reassigning <topology>-1-1407736491
to 1 slots
2014-08-11 05:56:51 b.s.d.nimbus [INFO] Reassign executors: [[2 2] [3 3] [4
4] [5 5] [6 6] [7 7] [8 8] [9 9] [10 10] [11 11] [12 12] [13 13] [14 14]
[15 15] [16 16] [17 17] [1 1]]
Why is this happening. I didnt find any errors and also no output in storm
ui. am I doing something wrong or my jar has problems?
ThankYou,
G V Chandrahas Raj
