beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Luke Cwik (JIRA)" <j...@apache.org>
Subject [jira] [Reopened] (BEAM-3336) MqttIO read tests are flaky
Date Fri, 12 Jan 2018 21:53:00 GMT

     [ 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)

Mime
View raw message