[
https://issues.apache.org/jira/browse/FLINK-3716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15231041#comment-15231041
]
Todd Lisonbee commented on FLINK-3716:
--------------------------------------
Most time is being spent at this point in the logs. Seems like the test moves
along fine for the first 3 seconds and then it hangs for about 3 minutes and
then it finishes in a few more seconds.
3200 [flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.testingUtils.TestingTaskManager - Memory usage stats:
[HEAP: 127/305/711 MB, NON HEAP: 45/46/-1 MB (used/committed/max)]
3210 [flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.testingUtils.TestingTaskManager - Trying to register
at JobManager akka.tcp://[email protected]:1424/user/jobmanager (attempt 1,
timeout: 500 milliseconds)
3237 [flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.instance.InstanceManager - Registered TaskManager at
gao-wse (akka.tcp://[email protected]:1524/user/taskmanager0) as
9a1f5ef24c0272e4bf0d6aca0697cbb1. Current number of registered hosts is 1.
Current number of alive task slots is 8.
3248 [flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.testingUtils.TestingTaskManager - Successful
registration at JobManager (akka.tcp://[email protected]:1424/user/jobmanager),
starting network stack and library cache.
3262 [flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.testingUtils.TestingTaskManager - Determined BLOB
server address to be /127.0.0.1:59077. Starting BLOB cache.
3263 [flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.blob.BlobCache - Created BLOB cache storage directory
/tmp/blobStore-0860fd56-6531-451a-b46c-996722835a6a
3271 [main] INFO org.apache.flink.streaming.connectors.kafka.Kafka08ITCase -
================================================================================
Test
testFailOnNoBroker(org.apache.flink.streaming.connectors.kafka.Kafka08ITCase)
is running.
--------------------------------------------------------------------------------
184995 [flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.testingUtils.TestingJobManager - Stopping JobManager
akka.tcp://[email protected]:1424/user/jobmanager.
184995 [flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.testingUtils.TestingTaskManager - Stopping
TaskManager akka://flink/user/taskmanager0#770941742.
184997 [flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.testingUtils.TestingTaskManager - Disassociating from
JobManager
185001 [flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.blob.BlobCache - Shutting down BlobCache
185011 [flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:59077
185015 [flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed
spill file directory /tmp/flink-io-b118915b-de93-4164-aad2-b5ff9ecc4c5e
185019 [flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.testingUtils.TestingTaskManager - Task manager
akka://flink/user/taskmanager0 is completely shut down.
185030 [main] INFO kafka.server.KafkaServer - [Kafka Server 0], shutting down
> 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)
