[ https://issues.apache.org/jira/browse/KAFKA-5872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Rajini Sivaram updated KAFKA-5872: ---------------------------------- Description: There are a couple of issues: 1. `Selector.determineHandlingOrder()` currently doesn't clear selection keys when keys are shuffled. This can result in select returning zero even when there are ready keys, resulting in a tight loop of polls with no keys processed. 2. The test expects `Selector.isOutOfMemory()` to be set in a poll that waits only for 10ms. This is expecting two reads from two connections to be processed within 10ms of each other, which may not always be the case. Error: {quote} org.apache.kafka.common.network.SslSelectorTest > testMuteOnOOM FAILED java.lang.AssertionError: could not initiate connections within timeout at org.junit.Assert.fail(Assert.java:88) at org.apache.kafka.common.network.SslSelectorTest.testMuteOnOOM(SslSelectorTest.java:236) {quote} was: There are a couple of issues: 1. `Selector.determineHandlingOrder()` currently doesn't clear selection keys when keys are shuffled. This can result in select returning zero even when there are ready keys, resulting in a tight loop of polls with no keys processed. 2. The test expects `Selector.isOutOfMemory()` to be set in a poll that waits only for 10ms. This is expecting two reads from two connections to be processed within 10ms of each other, which may not always be the case. > Transient failure in SslSelectorTest.testMuteOnOOM > -------------------------------------------------- > > Key: KAFKA-5872 > URL: https://issues.apache.org/jira/browse/KAFKA-5872 > Project: Kafka > Issue Type: Bug > Components: network > Reporter: Rajini Sivaram > Assignee: Rajini Sivaram > Fix For: 1.0.0 > > > There are a couple of issues: > 1. `Selector.determineHandlingOrder()` currently doesn't clear selection keys > when keys are shuffled. This can result in select returning zero even when > there are ready keys, resulting in a tight loop of polls with no keys > processed. > 2. The test expects `Selector.isOutOfMemory()` to be set in a poll that waits > only for 10ms. This is expecting two reads from two connections to be > processed within 10ms of each other, which may not always be the case. > Error: > {quote} > org.apache.kafka.common.network.SslSelectorTest > testMuteOnOOM FAILED > java.lang.AssertionError: could not initiate connections within timeout > at org.junit.Assert.fail(Assert.java:88) > at > org.apache.kafka.common.network.SslSelectorTest.testMuteOnOOM(SslSelectorTest.java:236) > {quote} -- This message was sent by Atlassian JIRA (v6.4.14#64029)