Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- LOGS from Kafka spout
- /var/log/storm/streaming-1-50-1444236724-worker-6703.log:2015-10-07 17:02:55 b.s.d.executor [INFO] Processing received message FOR 25 TUPLE: source: kafka-spout:21, stream: default, id: {6019011298234886534=-7787074016002797247}, [[B@550c0ea9]
- /var/log/storm/streaming-1-50-1444236724-worker-6703.log:2015-10-07 17:02:55 c.s.s.b.MyBolt [INFO] received auditId:b51258e4-6d14-11e5-9c6e-0a88dac902cf, messageId:{6019011298234886534=-7787074016002797247}
- /var/log/storm/streaming-1-50-1444236724-worker-6703.log:2015-10-07 17:02:55 c.s.s.b.MyBolt [INFO] processed auditId:b51258e4-6d14-11e5-9c6e-0a88dac902cf, messageId:{6019011298234886534=-7787074016002797247}
- /var/log/storm/streaming-1-50-1444236724-worker-6703.log:2015-10-07 17:02:55 b.s.d.task [INFO] Emitting: MyStream __ack_ack [6019011298234886534 -7787074016002797247]
- /var/log/storm/streaming-1-50-1444236724-worker-6703.log:2015-10-07 17:02:55 b.s.d.executor [INFO] TRANSFERING tuple TASK: 12 TUPLE: source: MyStream:25, stream: __ack_ack, id: {}, [6019011298234886534 -7787074016002797247]
- /var/log/storm/streaming-1-50-1444236724-worker-6703.log:2015-10-07 17:02:55 b.s.d.executor [INFO] BOLT ack TASK: 25 TIME: TUPLE: source: kafka-spout:21, stream: default, id: {6019011298234886534=-7787074016002797247}, [[B@550c0ea9]
- /var/log/storm/streaming-1-50-1444236724-worker-6703.log:2015-10-07 17:02:55 c.s.s.b.MyBolt [INFO] acked auditId:b51258e4-6d14-11e5-9c6e-0a88dac902cf, messageId:{6019011298234886534=-7787074016002797247}
- /var/log/storm/streaming-1-50-1444236724-worker-6703.log:2015-10-07 17:02:55 b.s.d.executor [INFO] Execute done TUPLE source: kafka-spout:21, stream: default, id: {6019011298234886534=-7787074016002797247}, [[B@550c0ea9] TASK: 25 DELTA:
- LOGS from relevant bolt's logs
- /var/log/storm/streaming-1-50-1444236724-worker-6703.log:2015-10-07 17:02:48 b.s.d.executor [INFO] TRANSFERING tuple TASK: 25 TUPLE: source: kafka-spout:21, stream: default, id: {6019011298234886534=-7787074016002797247}, [[B@3a27994f]
- /var/log/storm/streaming-1-50-1444236724-worker-6703.log:2015-10-07 17:02:48 b.s.d.task [INFO] Emitting: kafka-spout __ack_init [6019011298234886534 -7787074016002797247 21]
- /var/log/storm/streaming-1-50-1444236724-worker-6703.log:2015-10-07 17:02:48 b.s.d.executor [INFO] TRANSFERING tuple TASK: 12 TUPLE: source: kafka-spout:21, stream: __ack_init, id: {}, [6019011298234886534 -7787074016002797247 21]
- /var/log/storm/streaming-1-50-1444236724-worker-6703.log:2015-10-07 17:02:55 b.s.d.executor [INFO] Processing received message FOR 21 TUPLE: source: __acker:12, stream: __ack_ack, id: {}, [6019011298234886534]
- /var/log/storm/streaming-1-50-1444236724-worker-6703.log:2015-10-07 17:02:55 b.s.d.executor [INFO] SPOUT Acking message 6019011298234886534 (0,6155)
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement