[jira] [Updated] (CURATOR-308) SimpleDistributedQueue::take() hangs if container nodes are removed
[ https://issues.apache.org/jira/browse/CURATOR-308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jordan Zimmerman updated CURATOR-308: - Fix Version/s: (was: 2.10.1) > SimpleDistributedQueue::take() hangs if container nodes are removed > --- > > Key: CURATOR-308 > URL: https://issues.apache.org/jira/browse/CURATOR-308 > Project: Apache Curator > Issue Type: Bug > Components: Recipes >Affects Versions: 3.1.0 > Environment: org.apache.curator:curator-recipes 3.1.0 > org.apache.curator:curator-test 3.1.0 >Reporter: Philip Searle >Assignee: Jordan Zimmerman > Fix For: 3.1.1 > > Attachments: TestSimpleDistributedQueueHang.java > > > SimpleDistributedQueue creates the queue using container nodes if the > ZooKeeper instance supports this feature. If ZooKeeper runs the container > node cleanup task while SimpleDistributedQueue::take() is blocking, the call > will not ever return. > A similar issue occurs when calling poll(), resulting in it delaying until > the timeout has elapsed, even if a queue item was inserted after the > container cleanup occurs. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Updated] (CURATOR-308) SimpleDistributedQueue::take() hangs if container nodes are removed
[ https://issues.apache.org/jira/browse/CURATOR-308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jordan Zimmerman updated CURATOR-308: - Fix Version/s: 3.1.1 2.10.1 > SimpleDistributedQueue::take() hangs if container nodes are removed > --- > > Key: CURATOR-308 > URL: https://issues.apache.org/jira/browse/CURATOR-308 > Project: Apache Curator > Issue Type: Bug > Components: Recipes >Affects Versions: 3.1.0 > Environment: org.apache.curator:curator-recipes 3.1.0 > org.apache.curator:curator-test 3.1.0 >Reporter: Philip Searle >Assignee: Jordan Zimmerman > Fix For: 2.10.1, 3.1.1 > > Attachments: TestSimpleDistributedQueueHang.java > > > SimpleDistributedQueue creates the queue using container nodes if the > ZooKeeper instance supports this feature. If ZooKeeper runs the container > node cleanup task while SimpleDistributedQueue::take() is blocking, the call > will not ever return. > A similar issue occurs when calling poll(), resulting in it delaying until > the timeout has elapsed, even if a queue item was inserted after the > container cleanup occurs. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Updated] (CURATOR-308) SimpleDistributedQueue::take() hangs if container nodes are removed
[ https://issues.apache.org/jira/browse/CURATOR-308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Philip Searle updated CURATOR-308: -- Attachment: TestSimpleDistributedQueueHang.java Attached testcase demonstrating this issue. It creates two threads: one offering ten items to a queue with a seven second delay between offers; the other takes them with a three second delay. The ZooKeeper container check interval has been reduced to 1000 milliseconds. The expected behaviour is for ten items to be offered and taken. The actual behaviour is that the empty queue container node is removed after the first item is taken off the queue and the subsequent call to take() blocks forever. > SimpleDistributedQueue::take() hangs if container nodes are removed > --- > > Key: CURATOR-308 > URL: https://issues.apache.org/jira/browse/CURATOR-308 > Project: Apache Curator > Issue Type: Bug > Components: Recipes >Affects Versions: 3.1.0 > Environment: org.apache.curator:curator-recipes 3.1.0 > org.apache.curator:curator-test 3.1.0 >Reporter: Philip Searle > Attachments: TestSimpleDistributedQueueHang.java > > > SimpleDistributedQueue creates the queue using container nodes if the > ZooKeeper instance supports this feature. If ZooKeeper runs the container > node cleanup task while SimpleDistributedQueue::take() is blocking, the call > will not ever return. > A similar issue occurs when calling poll(), resulting in it delaying until > the timeout has elapsed, even if a queue item was inserted after the > container cleanup occurs. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Updated] (CURATOR-308) SimpleDistributedQueue::take() hangs if container nodes are removed
[ https://issues.apache.org/jira/browse/CURATOR-308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Philip Searle updated CURATOR-308: -- Environment: org.apache.curator:curator-recipes 3.1.0 org.apache.curator:curator-test 3.1.0 > SimpleDistributedQueue::take() hangs if container nodes are removed > --- > > Key: CURATOR-308 > URL: https://issues.apache.org/jira/browse/CURATOR-308 > Project: Apache Curator > Issue Type: Bug > Components: Recipes >Affects Versions: 3.1.0 > Environment: org.apache.curator:curator-recipes 3.1.0 > org.apache.curator:curator-test 3.1.0 >Reporter: Philip Searle > > SimpleDistributedQueue creates the queue using container nodes if the > ZooKeeper instance supports this feature. If ZooKeeper runs the container > node cleanup task while SimpleDistributedQueue::take() is blocking, the call > will not ever return. > A similar issue occurs when calling poll(), resulting in it delaying until > the timeout has elapsed, even if a queue item was inserted after the > container cleanup occurs. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
