[
https://issues.apache.org/jira/browse/FLINK-3716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15232374#comment-15232374
]
ASF GitHub Bot commented on FLINK-3716:
---------------------------------------
GitHub user tlisonbee opened a pull request:
https://github.com/apache/flink/pull/1864
[FLINK-3716] Kafka08ITCase.testFailOnNoBroker() fix
Decreasing socket timeout so that testFailOnNoBroker() will be able to pass
before the JUnit timeout.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/tlisonbee/flink FLINK-3716
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/1864.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #1864
----
commit c30f76392508ab743dfc56ff72cd9fc1fa4770a3
Author: Todd Lisonbee <todd.lison...@intel.com>
Date: 2016-04-08T00:47:19Z
[FLINK-3716] decreasing socket timeout so testFailOnNoBroker() will pass
before JUnit timeout
----
> 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
> Labels: test-stability
>
> 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)
