hi thanks for the reply, I am new to this could be elaborate about logging into bolts and spouts.Right now i am able to see the topology available in storm ui with thhe bolts and spouts. while submitting the jar i havent faced any problems.could you guide me through any debugging process to find the key problem.
ThankYou, G V Chandrahas Raj On Mon, Aug 11, 2014 at 6:48 PM, Spico Florin <[email protected]> wrote: > Hello! > Check your topology if it runs locally. Log your bolts, spouts to check > that are initialized correctly. Check that your jat file contains the > required libraries (except the storm jar files). It is possible to have > exception in the initialization phase in one of them. > > I hope that these help. > Regards, > Florin > > > > On Mon, Aug 11, 2014 at 10:01 AM, Chandrahas Gurram < > [email protected]> wrote: > >> 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 >> > >
