[ https://issues.apache.org/jira/browse/STORM-597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Rick Kellogg updated STORM-597: ------------------------------- Component/s: storm-core > spout not receve the message acker > ---------------------------------- > > Key: STORM-597 > URL: https://issues.apache.org/jira/browse/STORM-597 > Project: Apache Storm > Issue Type: Bug > Components: storm-core > Affects Versions: 0.9.3 > Reporter: ryan.jin > > I have one spout and one bolt. > The program always runs greate. But sometimes the spout do not receive the > ack and at debug mode the bolt have do the ack correctly. > LOG: > ###1 Normally the last line says the spout has received acker. > 2014-12-21 02:46:15 c.s.b.s.b.s.BaseTaskScheduleSpout [INFO] check time begin > at :2014-12-21 02:46:15 end > 2014-12-21 02:46:15 b.s.d.task [INFO] Emitting: task-spout default > [1419100920000, 1419100980000] > 2014-12-21 02:46:15 b.s.d.task [INFO] Emitting: task-spout __ack_init > [3492883688624743717 -7308083944080730032 10] > 2014-12-21 02:46:15 b.s.d.executor [INFO] Processing received message source: > task-spout:10, stream: default, id: > {3492883688624743717=-7308083944080730032}, [1419100920000, 1419100980000] > 2014-12-21 02:46:15 b.s.d.executor [INFO] Processing received message source: > task-spout:10, stream: __ack_init, id: {}, [3492883688624743717 > -7308083944080730032 10] > 2014-12-21 02:46:15 c.s.b.s.b.b.HbaseTaskScheduleBolt [INFO] table > prmt_user_tracer scan 0 cost 3 ms time 2014-12-21 > 02:42:00 to 2014-12-21 02:43:00 row null to null > 2014-12-21 02:46:15 c.s.b.s.b.b.HbaseTaskScheduleBolt [INFO] table > prmt_user_tracer run final success > 2014-12-21 02:46:15 b.s.d.task [INFO] Emitting: task-bolt __ack_ack > [3492883688624743717 -7308083944080730032] > 2014-12-21 02:46:15 b.s.d.executor [INFO] Processing received message source: > task-bolt:7, stream: __ack_ack, id: {}, [3492883688624743717 > -7308083944080730032] > 2014-12-21 02:46:15 b.s.d.task [INFO] Emitting direct: 10; __acker __ack_ack > [3492883688624743717] > 2014-12-21 02:46:15 b.s.d.executor [INFO] Processing received message source: > __acker:1, stream: __ack_ack, id: {}, [3492883688624743717] > 2014-12-21 02:46:15 b.s.d.executor [INFO] Acking message > 1419100920000,1419100980000,60000,prmt_user_tracer,true,1419101175675,from:2014-12-21 > 02:42:00,to:2014-12-21 02:43:00,execute:2014-12-21 02:46:15 > ###2.bug case, the bolt ack is stopping at "Emitting direct: 10; __acker > __ack_ack [-5576733886177167329]". And the spout will not receve the ack of > that message. > 2014-12-21 02:45:15 c.s.b.s.b.s.BaseTaskScheduleSpout [INFO] begin put task > > 1419100860000,1419100920000,60000,prmt_user_tracer,true,1419101115112,from:2014-12-21 > 02:41:00,to:2014-12-21 02:42:00,execute:2014-12-21 02:45:15 > 2014-12-21 02:45:15 c.s.b.s.b.s.BaseTaskScheduleSpout [INFO] check time begin > at :2014-12-21 02:45:14 end > 2014-12-21 02:45:15 b.s.d.task [INFO] Emitting: task-spout default > [1419100860000, 1419100920000] > 2014-12-21 02:45:15 b.s.d.task [INFO] Emitting: task-spout __ack_init > [-5576733886177167329 6447998047515384780 10] > 2014-12-21 02:45:15 b.s.d.executor [INFO] Processing received message source: > task-spout:10, stream: default, id: > {-5576733886177167329=6447998047515384780}, [1419100860000, 1419100920000] > 2014-12-21 02:45:15 b.s.d.executor [INFO] Processing received message source: > task-spout:10, stream: __ack_init, id: {}, [-5576733886177167329 > 6447998047515384780 10] > 2014-12-21 02:45:15 c.s.b.s.b.b.HbaseTaskScheduleBolt [INFO] table > prmt_user_tracer scan 0 cost 4 ms time 2014-12-21 > 02:41:00 to 2014-12-21 02:42:00 row null to null > 2014-12-21 02:45:15 c.s.b.s.b.b.HbaseTaskScheduleBolt [INFO] table > prmt_user_tracer run final success > 2014-12-21 02:45:15 b.s.d.task [INFO] Emitting: task-bolt __ack_ack > [-5576733886177167329 6447998047515384780] > 2014-12-21 02:45:15 b.s.d.executor [INFO] Processing received message source: > task-bolt:5, stream: __ack_ack, id: {}, [-5576733886177167329 > 6447998047515384780] > 2014-12-21 02:45:15 b.s.d.task [INFO] Emitting direct: 10; __acker __ack_ack > [-5576733886177167329] -- This message was sent by Atlassian JIRA (v6.3.4#6332)