Advertisement
Guest User

Untitled

a guest
Oct 7th, 2015
162
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 2.73 KB | None | 0 0
  1. LOGS from Kafka spout
  2. /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]
  3. /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}
  4. /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}
  5. /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]
  6. /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]
  7. /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]
  8. /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}
  9. /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:
  10.  
  11.  
  12. LOGS from relevant bolt's logs
  13.  
  14. /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]
  15. /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]
  16. /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]
  17. /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]
  18. /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