You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by "Luke Cwik (JIRA)" <ji...@apache.org> on 2018/01/12 21:53:00 UTC
[jira] [Reopened] (BEAM-3336) MqttIO read tests are flaky
[ https://issues.apache.org/jira/browse/BEAM-3336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Luke Cwik reopened BEAM-3336:
-----------------------------
Another example failure: https://builds.apache.org/job/beam_PreCommit_Java_GradleBuild/1032/
Failed:
org.apache.beam.sdk.io.mqtt.MqttIOTest.testRead
org.apache.beam.sdk.io.mqtt.MqttIOTest.testReadNoClientId
Logs:
org.junit.runners.model.TestTimedOutException: test timed out after 60000 milliseconds
Stacktrace
org.junit.runners.model.TestTimedOutException: test timed out after 60000 milliseconds
at sun.misc.Unsafe.park(Native Method)
at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)
at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078)
at java.util.concurrent.LinkedBlockingQueue.poll(LinkedBlockingQueue.java:467)
at org.apache.beam.runners.direct.ExecutorServiceParallelExecutor$QueueMessageReceiver.tryNext(ExecutorServiceParallelExecutor.java:357)
at org.apache.beam.runners.direct.ExecutorServiceParallelExecutor$QueueMessageReceiver.access$300(ExecutorServiceParallelExecutor.java:328)
at org.apache.beam.runners.direct.ExecutorServiceParallelExecutor.waitUntilFinish(ExecutorServiceParallelExecutor.java:241)
at org.apache.beam.runners.direct.DirectRunner$DirectPipelineResult.waitUntilFinish(DirectRunner.java:334)
at org.apache.beam.runners.direct.DirectRunner$DirectPipelineResult.waitUntilFinish(DirectRunner.java:309)
at org.apache.beam.runners.direct.DirectRunner.run(DirectRunner.java:203)
at org.apache.beam.runners.direct.DirectRunner.run(DirectRunner.java:63)
at org.apache.beam.sdk.Pipeline.run(Pipeline.java:304)
at org.apache.beam.sdk.testing.TestPipeline.run(TestPipeline.java:358)
at org.apache.beam.sdk.testing.TestPipeline.run(TestPipeline.java:340)
at org.apache.beam.sdk.io.mqtt.MqttIOTest.testReadNoClientId(MqttIOTest.java:133)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
at org.junit.internal.runners.statements.FailOnTimeout$CallableStatement.call(FailOnTimeout.java:298)
at org.junit.internal.runners.statements.FailOnTimeout$CallableStatement.call(FailOnTimeout.java:292)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.lang.Thread.run(Thread.java:748)
Standard Error
Jan 12, 2018 8:54:27 PM org.apache.beam.sdk.io.mqtt.MqttIOTest startBroker
INFO: Finding free network port
Jan 12, 2018 8:54:27 PM org.apache.beam.sdk.io.mqtt.MqttIOTest startBroker
INFO: Starting ActiveMQ brokerService on 33991
Jan 12, 2018 8:54:30 PM org.apache.activemq.broker.BrokerService doStartPersistenceAdapter
INFO: Using Persistence Adapter: MemoryPersistenceAdapter
Jan 12, 2018 8:54:31 PM org.apache.activemq.broker.BrokerService doStartBroker
INFO: Apache ActiveMQ 5.13.1 (localhost, ID:52.16.184.35.bc.googleusercontent.com-36581-1515790470484-0:1) is starting
Jan 12, 2018 8:54:31 PM org.apache.activemq.transport.TransportServerThreadSupport doStart
INFO: Listening for connections at: mqtt://localhost:33991
Jan 12, 2018 8:54:31 PM org.apache.activemq.broker.TransportConnector start
INFO: Connector mqtt://localhost:33991 started
Jan 12, 2018 8:54:31 PM org.apache.activemq.broker.BrokerService doStartBroker
INFO: Apache ActiveMQ 5.13.1 (localhost, ID:52.16.184.35.bc.googleusercontent.com-36581-1515790470484-0:1) started
Jan 12, 2018 8:54:31 PM org.apache.activemq.broker.BrokerService doStartBroker
INFO: For help or more information please see: http://activemq.apache.org
Jan 12, 2018 8:54:54 PM org.apache.activemq.broker.BrokerService stop
INFO: Apache ActiveMQ 5.13.1 (localhost, ID:52.16.184.35.bc.googleusercontent.com-36581-1515790470484-0:1) is shutting down
Jan 12, 2018 8:54:54 PM org.apache.activemq.broker.TransportConnection serviceTransportException
WARNING: Transport Connection to: tcp://127.0.0.1:50644 failed: java.io.IOException: Unexpected error occurred: org.apache.activemq.broker.BrokerStoppedException: Broker BrokerService[localhost] is being stopped
Jan 12, 2018 8:54:55 PM org.apache.activemq.broker.TransportConnector stop
INFO: Connector mqtt://localhost:33991 stopped
Jan 12, 2018 8:54:55 PM org.apache.activemq.broker.BrokerService stop
INFO: Apache ActiveMQ 5.13.1 (localhost, ID:52.16.184.35.bc.googleusercontent.com-36581-1515790470484-0:1) uptime 26.546 seconds
Jan 12, 2018 8:54:55 PM org.apache.activemq.broker.BrokerService stop
INFO: Apache ActiveMQ 5.13.1 (localhost, ID:52.16.184.35.bc.googleusercontent.com-36581-1515790470484-0:1) is shutdown
Jan 12, 2018 8:54:55 PM org.apache.beam.sdk.io.mqtt.MqttIOTest startBroker
INFO: Finding free network port
Jan 12, 2018 8:54:55 PM org.apache.beam.sdk.io.mqtt.MqttIOTest startBroker
INFO: Starting ActiveMQ brokerService on 38105
Jan 12, 2018 8:54:55 PM org.apache.activemq.broker.BrokerService doStartPersistenceAdapter
INFO: Using Persistence Adapter: MemoryPersistenceAdapter
Jan 12, 2018 8:54:55 PM org.apache.activemq.broker.BrokerService doStartBroker
INFO: Apache ActiveMQ 5.13.1 (localhost, ID:52.16.184.35.bc.googleusercontent.com-36581-1515790470484-0:2) is starting
Jan 12, 2018 8:54:55 PM org.apache.activemq.transport.TransportServerThreadSupport doStart
INFO: Listening for connections at: mqtt://localhost:38105
Jan 12, 2018 8:54:55 PM org.apache.activemq.broker.TransportConnector start
INFO: Connector mqtt://localhost:38105 started
Jan 12, 2018 8:54:55 PM org.apache.activemq.broker.BrokerService doStartBroker
INFO: Apache ActiveMQ 5.13.1 (localhost, ID:52.16.184.35.bc.googleusercontent.com-36581-1515790470484-0:2) started
Jan 12, 2018 8:54:55 PM org.apache.activemq.broker.BrokerService doStartBroker
INFO: For help or more information please see: http://activemq.apache.org
Jan 12, 2018 8:54:57 PM org.apache.beam.sdk.io.mqtt.MqttIOTest$2 run
INFO: Waiting pipeline connected to the MQTT broker before sending messages ...
Jan 12, 2018 8:55:00 PM org.apache.activemq.broker.BrokerService stop
INFO: Apache ActiveMQ 5.13.1 (localhost, ID:52.16.184.35.bc.googleusercontent.com-36581-1515790470484-0:2) is shutting down
Jan 12, 2018 8:55:00 PM org.apache.activemq.broker.TransportConnector stop
INFO: Connector mqtt://localhost:38105 stopped
Jan 12, 2018 8:55:00 PM org.apache.activemq.broker.BrokerService stop
INFO: Apache ActiveMQ 5.13.1 (localhost, ID:52.16.184.35.bc.googleusercontent.com-36581-1515790470484-0:2) uptime 5.353 seconds
Jan 12, 2018 8:55:00 PM org.apache.activemq.broker.BrokerService stop
INFO: Apache ActiveMQ 5.13.1 (localhost, ID:52.16.184.35.bc.googleusercontent.com-36581-1515790470484-0:2) is shutdown
Jan 12, 2018 8:55:00 PM org.apache.beam.sdk.io.mqtt.MqttIOTest startBroker
INFO: Finding free network port
Jan 12, 2018 8:55:00 PM org.apache.beam.sdk.io.mqtt.MqttIOTest startBroker
INFO: Starting ActiveMQ brokerService on 44050
Jan 12, 2018 8:55:00 PM org.apache.activemq.broker.BrokerService doStartPersistenceAdapter
INFO: Using Persistence Adapter: MemoryPersistenceAdapter
Jan 12, 2018 8:55:00 PM org.apache.activemq.broker.BrokerService doStartBroker
INFO: Apache ActiveMQ 5.13.1 (localhost, ID:52.16.184.35.bc.googleusercontent.com-36581-1515790470484-0:3) is starting
Jan 12, 2018 8:55:00 PM org.apache.activemq.transport.TransportServerThreadSupport doStart
INFO: Listening for connections at: mqtt://localhost:44050
Jan 12, 2018 8:55:00 PM org.apache.activemq.broker.TransportConnector start
INFO: Connector mqtt://localhost:44050 started
Jan 12, 2018 8:55:00 PM org.apache.activemq.broker.BrokerService doStartBroker
INFO: Apache ActiveMQ 5.13.1 (localhost, ID:52.16.184.35.bc.googleusercontent.com-36581-1515790470484-0:3) started
Jan 12, 2018 8:55:00 PM org.apache.activemq.broker.BrokerService doStartBroker
INFO: For help or more information please see: http://activemq.apache.org
Jan 12, 2018 8:55:03 PM org.apache.activemq.broker.BrokerService stop
INFO: Apache ActiveMQ 5.13.1 (localhost, ID:52.16.184.35.bc.googleusercontent.com-36581-1515790470484-0:3) is shutting down
Jan 12, 2018 8:55:03 PM org.apache.activemq.broker.TransportConnector stop
INFO: Connector mqtt://localhost:44050 stopped
Jan 12, 2018 8:55:03 PM org.apache.activemq.broker.BrokerService stop
INFO: Apache ActiveMQ 5.13.1 (localhost, ID:52.16.184.35.bc.googleusercontent.com-36581-1515790470484-0:3) uptime 2.885 seconds
Jan 12, 2018 8:55:03 PM org.apache.activemq.broker.BrokerService stop
INFO: Apache ActiveMQ 5.13.1 (localhost, ID:52.16.184.35.bc.googleusercontent.com-36581-1515790470484-0:3) is shutdown
Jan 12, 2018 8:55:03 PM org.apache.beam.sdk.io.mqtt.MqttIOTest startBroker
INFO: Finding free network port
Jan 12, 2018 8:55:03 PM org.apache.beam.sdk.io.mqtt.MqttIOTest startBroker
INFO: Starting ActiveMQ brokerService on 38757
Jan 12, 2018 8:55:03 PM org.apache.activemq.broker.BrokerService doStartPersistenceAdapter
INFO: Using Persistence Adapter: MemoryPersistenceAdapter
Jan 12, 2018 8:55:03 PM org.apache.activemq.broker.BrokerService doStartBroker
INFO: Apache ActiveMQ 5.13.1 (localhost, ID:52.16.184.35.bc.googleusercontent.com-36581-1515790470484-0:4) is starting
Jan 12, 2018 8:55:03 PM org.apache.activemq.transport.TransportServerThreadSupport doStart
INFO: Listening for connections at: mqtt://localhost:38757
Jan 12, 2018 8:55:03 PM org.apache.activemq.broker.TransportConnector start
INFO: Connector mqtt://localhost:38757 started
Jan 12, 2018 8:55:03 PM org.apache.activemq.broker.BrokerService doStartBroker
INFO: Apache ActiveMQ 5.13.1 (localhost, ID:52.16.184.35.bc.googleusercontent.com-36581-1515790470484-0:4) started
Jan 12, 2018 8:55:03 PM org.apache.activemq.broker.BrokerService doStartBroker
INFO: For help or more information please see: http://activemq.apache.org
Jan 12, 2018 8:55:04 PM org.apache.beam.sdk.io.mqtt.MqttIOTest$1 run
INFO: Waiting pipeline connected to the MQTT broker before sending messages ...
Jan 12, 2018 8:56:03 PM org.apache.activemq.broker.BrokerService stop
INFO: Apache ActiveMQ 5.13.1 (localhost, ID:52.16.184.35.bc.googleusercontent.com-36581-1515790470484-0:4) is shutting down
Jan 12, 2018 8:56:04 PM org.apache.activemq.broker.TransportConnector stop
INFO: Connector mqtt://localhost:38757 stopped
Jan 12, 2018 8:56:04 PM org.apache.activemq.broker.BrokerService stop
INFO: Apache ActiveMQ 5.13.1 (localhost, ID:52.16.184.35.bc.googleusercontent.com-36581-1515790470484-0:4) uptime 1 minute
Jan 12, 2018 8:56:04 PM org.apache.activemq.broker.BrokerService stop
INFO: Apache ActiveMQ 5.13.1 (localhost, ID:52.16.184.35.bc.googleusercontent.com-36581-1515790470484-0:4) is shutdown
> MqttIO read tests are flaky
> ---------------------------
>
> Key: BEAM-3336
> URL: https://issues.apache.org/jira/browse/BEAM-3336
> Project: Beam
> Issue Type: Bug
> Components: sdk-java-extensions
> Reporter: Thomas Groh
> Assignee: Jean-Baptiste Onofré
> Fix For: 2.3.0
>
>
> example failure: https://builds.apache.org/job/beam_PreCommit_Java_GradleBuild/449/
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)