Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-3716

Kafka08ITCase.testFailOnNoBroker() timing out before it has a chance to pass

Attach filesAttach ScreenshotVotersWatch issueWatchersCreate sub-taskLinkCloneUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Closed
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: None
    • Fix Version/s: 1.0.2, 1.1.0
    • Component/s: None
    • Labels:

      Description

      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)

        Attachments

          Activity

            People

            • Assignee:
              tlisonbee Todd Lisonbee
              Reporter:
              tlisonbee Todd Lisonbee

              Dates

              • Created:
                Updated:
                Resolved:

                Issue deployment