[
https://issues.apache.org/jira/browse/FLINK-3716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15231380#comment-15231380
]
Todd Lisonbee commented on FLINK-3716:
--------------------------------------
I enabled more logging to see what was happening during the lost 3 minutes. It
appears to be trying multiple times and timing out each time. This appears to
me to be reasonable and likely the intended behavior but I'm not sure why this
would be failing on my system but not the build server. Seems like either I'm
missing some needed settings or there are Linux settings that are different on
my machine.
3184 [main] INFO org.apache.flink.streaming.connectors.kafka.Kafka08ITCase -
================================================================================
Test
testFailOnNoBroker(org.apache.flink.streaming.connectors.kafka.Kafka08ITCase)
is running.
--------------------------------------------------------------------------------
3205 [Thread-14] INFO
org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer08 - Trying to
get topic metadata from broker localhost:80 in try 0/3
33255 [Thread-14] INFO kafka.consumer.SimpleConsumer - Reconnect due to
socket error: java.net.SocketTimeoutException
63290 [Thread-14] WARN
org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer08 - Error
communicating with broker localhost:80 to find partitions for
[doesntexist].class java.net.SocketTimeoutException. Message: null
63791 [Thread-14] INFO
org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer08 - Trying to
get topic metadata from broker localhost:80 in try 1/3
93823 [Thread-14] INFO kafka.consumer.SimpleConsumer - Reconnect due to
socket error: java.net.SocketTimeoutException
123849 [Thread-14] WARN
org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer08 - Error
communicating with broker localhost:80 to find partitions for
[doesntexist].class java.net.SocketTimeoutException. Message: null
124349 [Thread-14] INFO
org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer08 - Trying to
get topic metadata from broker localhost:80 in try 2/3
154378 [Thread-14] INFO kafka.consumer.SimpleConsumer - Reconnect due to
socket error: java.net.SocketTimeoutException
184382 [Thread-14] WARN
org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer08 - Error
communicating with broker localhost:80 to find partitions for
[doesntexist].class java.net.SocketTimeoutException. Message: null
184886 [main] INFO org.apache.flink.streaming.connectors.kafka.Kafka08ITCase
-
--------------------------------------------------------------------------------
Test
testFailOnNoBroker(org.apache.flink.streaming.connectors.kafka.Kafka08ITCase)
successfully run.
================================================================================
184888 [main] INFO org.apache.flink.streaming.connectors.kafka.KafkaTestBase
- -------------------------------------------------------------------------
184888 [main] INFO org.apache.flink.streaming.connectors.kafka.KafkaTestBase
- Shut down KafkaTestBase
184888 [main] INFO org.apache.flink.streaming.connectors.kafka.KafkaTestBase
- -------------------------------------------------------------------------
184900 [flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.testingUtils.TestingTaskManager - Stopping
TaskManager akka://flink/user/taskmanager0#1733825815.
184900 [flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.testingUtils.TestingJobManager - Stopping JobManager
akka.tcp://[email protected]:1424/user/jobmanager.
184901 [flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.testingUtils.TestingTaskManager - Disassociating from
JobManager
184903 [flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.blob.BlobCache - Shutting down BlobCache
> 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
>
> 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)
