Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- This is the log from the kafka spout which shows that the message timed out.
- /var/log/storm/mapi-streaming-1-15-1444259220-worker-6704.log:2015-10-08 03:42:15 b.s.d.executor [INFO] TRANSFERING tuple TASK: 22 TUPLE: source: kafka-spout:21, stream: default, id: {591583493557041328=2314606242348824781}, [[B@1bb073fc]
- /var/log/storm/mapi-streaming-1-15-1444259220-worker-6704.log:2015-10-08 03:42:15 b.s.d.task [INFO] Emitting: kafka-spout __ack_init [591583493557041328 2314606242348824781 21]
- /var/log/storm/mapi-streaming-1-15-1444259220-worker-6704.log:2015-10-08 03:42:15 b.s.d.executor [INFO] TRANSFERING tuple TASK: 13 TUPLE: source: kafka-spout:21, stream: __ack_init, id: {}, [591583493557041328 2314606242348824781 21]
- /var/log/storm/mapi-streaming-1-15-1444259220-worker-6704.log:2015-10-08 03:52:15 b.s.d.executor [INFO] SPOUT Failing 591583493557041328: {:stream "default", :values [#<byte[] [B@1bb073fc>]} REASON: TIMEOUT MSG-ID: (0,117027)
- This is the log from the machine running the Bolt. I have a log statement as the very first line in the bolt's execute method which prints the tuple. Looks like the message never went in to the bolt's execute method.
- /var/log/storm/mapi-streaming-1-15-1444259220-worker-6701.log:2015-10-08 03:42:15 b.s.d.executor [INFO] Processing received message FOR 13 TUPLE: source: kafka-spout:21, stream: __ack_init, id: {}, [591583493557041328, 2314606242348824781, 21]
- /var/log/storm/mapi-streaming-1-15-1444259220-worker-6701.log:2015-10-08 03:42:15 b.s.d.executor [INFO] BOLT ack TASK: 13 TIME: 0 TUPLE: source: kafka-spout:21, stream: __ack_init, id: {}, [591583493557041328, 2314606242348824781, 21]
- /var/log/storm/mapi-streaming-1-15-1444259220-worker-6701.log:2015-10-08 03:42:15 b.s.d.executor [INFO] Execute done TUPLE source: kafka-spout:21, stream: __ack_init, id: {}, [591583493557041328, 2314606242348824781, 21] TASK: 13 DELTA:
Advertisement
Add Comment
Please, Sign In to add comment