[jira] [Closed] (FLINK-3716) Kafka08ITCase.testFailOnNoBroker() timing out before it has a chance to pass

["Stephan Ewen (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-3716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Stephan Ewen closed FLINK-3716.
-------------------------------

> Kafka08ITCase.testFailOnNoBroker() timing out before it has a chance to pass
> ----------------------------------------------------------------------------
>
>                 Key: FLINK-3716
>                 URL: https://issues.apache.org/jira/browse/FLINK-3716
>             Project: Flink
>          Issue Type: Bug
>            Reporter: Todd Lisonbee
>            Assignee: Todd Lisonbee
>              Labels: test-stability
>             Fix For: 1.1.0, 1.0.2
>
>
> This is on the latest master 4/7/2016 with `mvn clean verify`.  
> Test also reliably fails running it directly from IntelliJ.
> Test has a 60 second timeout but it seems to need much more time to run (my workstation has server class Xeon).
> Test testFailOnNoBroker(org.apache.flink.streaming.connectors.kafka.Kafka08ITCase) failed with:
> java.lang.Exception: test timed out after 60000 milliseconds
> 	at sun.nio.ch.Net.poll(Native Method)
> 	at sun.nio.ch.SocketChannelImpl.poll(SocketChannelImpl.java:954)
> 	at sun.nio.ch.SocketAdaptor$SocketInputStream.read(SocketAdaptor.java:204)
> 	at sun.nio.ch.ChannelInputStream.read(ChannelInputStream.java:103)
> 	at java.nio.channels.Channels$ReadableByteChannelImpl.read(Channels.java:385)
> 	at kafka.utils.Utils$.read(Utils.scala:380)
> 	at kafka.network.BoundedByteBufferReceive.readFrom(BoundedByteBufferReceive.scala:54)
> 	at kafka.network.Receive$class.readCompletely(Transmission.scala:56)
> 	at kafka.network.BoundedByteBufferReceive.readCompletely(BoundedByteBufferReceive.scala:29)
> 	at kafka.network.BlockingChannel.receive(BlockingChannel.scala:111)
> 	at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
> 	at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:68)
> 	at kafka.consumer.SimpleConsumer.send(SimpleConsumer.scala:91)
> 	at kafka.javaapi.consumer.SimpleConsumer.send(SimpleConsumer.scala:68)
> 	at org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer08.getPartitionsForTopic(FlinkKafkaConsumer08.java:521)
> 	at org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer08.<init>(FlinkKafkaConsumer08.java:218)
> 	at org.apache.flink.streaming.connectors.kafka.KafkaTestEnvironmentImpl.getConsumer(KafkaTestEnvironmentImpl.java:95)
> 	at org.apache.flink.streaming.connectors.kafka.KafkaTestEnvironment.getConsumer(KafkaTestEnvironment.java:65)
> 	at org.apache.flink.streaming.connectors.kafka.KafkaTestEnvironment.getConsumer(KafkaTestEnvironment.java:73)
> 	at org.apache.flink.streaming.connectors.kafka.KafkaConsumerTestBase.runFailOnNoBrokerTest(KafkaConsumerTestBase.java:155)
> 	at org.apache.flink.streaming.connectors.kafka.Kafka08ITCase.testFailOnNoBroker(Kafka08ITCase.java:54)



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)