[ https://issues.apache.org/jira/browse/BEAM-3604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16384976#comment-16384976 ]
Jean-Baptiste Onofré commented on BEAM-3604: -------------------------------------------- Let me take a look but I think it's already fixed. > MqttIOTest testReadNoClientId failure timeout > --------------------------------------------- > > Key: BEAM-3604 > URL: https://issues.apache.org/jira/browse/BEAM-3604 > Project: Beam > Issue Type: Bug > Components: io-java-mqtt > Reporter: Kenneth Knowles > Assignee: Jean-Baptiste Onofré > Priority: Critical > Labels: flake > > I've seen failures a bit today. Here is one: > [https://builds.apache.org/job/beam_PreCommit_Java_GradleBuild/1758/testReport/junit/org.apache.beam.sdk.io.mqtt/MqttIOTest/testReadNoClientId/] > Filing all flakes as "Critical" priority so we can sickbay or fix. > Since that build will get GC'd, here is the Standard Error. It looks like > from that perspective everything went as planned, but perhaps the test has a > race condition or something? > {code} > Feb 01, 2018 11:28:01 PM org.apache.beam.sdk.io.mqtt.MqttIOTest startBroker > INFO: Finding free network port > Feb 01, 2018 11:28:01 PM org.apache.beam.sdk.io.mqtt.MqttIOTest startBroker > INFO: Starting ActiveMQ brokerService on 57986 > Feb 01, 2018 11:28:03 PM org.apache.activemq.broker.BrokerService > doStartPersistenceAdapter > INFO: Using Persistence Adapter: MemoryPersistenceAdapter > Feb 01, 2018 11:28:04 PM org.apache.activemq.broker.BrokerService > doStartBroker > INFO: Apache ActiveMQ 5.13.1 (localhost, > ID:115.98.154.104.bc.googleusercontent.com-38646-1517527683931-0:1) is > starting > Feb 01, 2018 11:28:04 PM > org.apache.activemq.transport.TransportServerThreadSupport doStart > INFO: Listening for connections at: mqtt://localhost:57986 > Feb 01, 2018 11:28:04 PM org.apache.activemq.broker.TransportConnector start > INFO: Connector mqtt://localhost:57986 started > Feb 01, 2018 11:28:04 PM org.apache.activemq.broker.BrokerService > doStartBroker > INFO: Apache ActiveMQ 5.13.1 (localhost, > ID:115.98.154.104.bc.googleusercontent.com-38646-1517527683931-0:1) started > Feb 01, 2018 11:28:04 PM org.apache.activemq.broker.BrokerService > doStartBroker > INFO: For help or more information please see: http://activemq.apache.org > Feb 01, 2018 11:28:26 PM org.apache.activemq.broker.BrokerService stop > INFO: Apache ActiveMQ 5.13.1 (localhost, > ID:115.98.154.104.bc.googleusercontent.com-38646-1517527683931-0:1) is > shutting down > Feb 01, 2018 11:28:26 PM org.apache.activemq.broker.TransportConnector stop > INFO: Connector mqtt://localhost:57986 stopped > Feb 01, 2018 11:28:26 PM org.apache.activemq.broker.BrokerService stop > INFO: Apache ActiveMQ 5.13.1 (localhost, > ID:115.98.154.104.bc.googleusercontent.com-38646-1517527683931-0:1) uptime > 24.039 seconds > Feb 01, 2018 11:28:26 PM org.apache.activemq.broker.BrokerService stop > INFO: Apache ActiveMQ 5.13.1 (localhost, > ID:115.98.154.104.bc.googleusercontent.com-38646-1517527683931-0:1) is > shutdown > Feb 01, 2018 11:28:26 PM org.apache.beam.sdk.io.mqtt.MqttIOTest startBroker > INFO: Finding free network port > Feb 01, 2018 11:28:26 PM org.apache.beam.sdk.io.mqtt.MqttIOTest startBroker > INFO: Starting ActiveMQ brokerService on 46799 > Feb 01, 2018 11:28:26 PM org.apache.activemq.broker.BrokerService > doStartPersistenceAdapter > INFO: Using Persistence Adapter: MemoryPersistenceAdapter > Feb 01, 2018 11:28:26 PM org.apache.activemq.broker.BrokerService > doStartBroker > INFO: Apache ActiveMQ 5.13.1 (localhost, > ID:115.98.154.104.bc.googleusercontent.com-38646-1517527683931-0:2) is > starting > Feb 01, 2018 11:28:26 PM > org.apache.activemq.transport.TransportServerThreadSupport doStart > INFO: Listening for connections at: mqtt://localhost:46799 > Feb 01, 2018 11:28:26 PM org.apache.activemq.broker.TransportConnector start > INFO: Connector mqtt://localhost:46799 started > Feb 01, 2018 11:28:26 PM org.apache.activemq.broker.BrokerService > doStartBroker > INFO: Apache ActiveMQ 5.13.1 (localhost, > ID:115.98.154.104.bc.googleusercontent.com-38646-1517527683931-0:2) started > Feb 01, 2018 11:28:26 PM org.apache.activemq.broker.BrokerService > doStartBroker > INFO: For help or more information please see: http://activemq.apache.org > Feb 01, 2018 11:28:28 PM org.apache.beam.sdk.io.mqtt.MqttIOTest > lambda$testRead$1 > INFO: Waiting pipeline connected to the MQTT broker before sending messages > ... > Feb 01, 2018 11:28:35 PM org.apache.activemq.broker.BrokerService stop > INFO: Apache ActiveMQ 5.13.1 (localhost, > ID:115.98.154.104.bc.googleusercontent.com-38646-1517527683931-0:2) is > shutting down > Feb 01, 2018 11:28:35 PM org.apache.activemq.broker.TransportConnector stop > INFO: Connector mqtt://localhost:46799 stopped > Feb 01, 2018 11:28:35 PM org.apache.activemq.broker.BrokerService stop > INFO: Apache ActiveMQ 5.13.1 (localhost, > ID:115.98.154.104.bc.googleusercontent.com-38646-1517527683931-0:2) uptime > 9.430 seconds > Feb 01, 2018 11:28:35 PM org.apache.activemq.broker.BrokerService stop > INFO: Apache ActiveMQ 5.13.1 (localhost, > ID:115.98.154.104.bc.googleusercontent.com-38646-1517527683931-0:2) is > shutdown > Feb 01, 2018 11:28:35 PM org.apache.beam.sdk.io.mqtt.MqttIOTest startBroker > INFO: Finding free network port > Feb 01, 2018 11:28:35 PM org.apache.beam.sdk.io.mqtt.MqttIOTest startBroker > INFO: Starting ActiveMQ brokerService on 54229 > Feb 01, 2018 11:28:35 PM org.apache.activemq.broker.BrokerService > doStartPersistenceAdapter > INFO: Using Persistence Adapter: MemoryPersistenceAdapter > Feb 01, 2018 11:28:35 PM org.apache.activemq.broker.BrokerService > doStartBroker > INFO: Apache ActiveMQ 5.13.1 (localhost, > ID:115.98.154.104.bc.googleusercontent.com-38646-1517527683931-0:3) is > starting > Feb 01, 2018 11:28:35 PM > org.apache.activemq.transport.TransportServerThreadSupport doStart > INFO: Listening for connections at: mqtt://localhost:54229 > Feb 01, 2018 11:28:35 PM org.apache.activemq.broker.TransportConnector start > INFO: Connector mqtt://localhost:54229 started > Feb 01, 2018 11:28:35 PM org.apache.activemq.broker.BrokerService > doStartBroker > INFO: Apache ActiveMQ 5.13.1 (localhost, > ID:115.98.154.104.bc.googleusercontent.com-38646-1517527683931-0:3) started > Feb 01, 2018 11:28:35 PM org.apache.activemq.broker.BrokerService > doStartBroker > INFO: For help or more information please see: http://activemq.apache.org > Feb 01, 2018 11:28:38 PM org.apache.activemq.broker.BrokerService stop > INFO: Apache ActiveMQ 5.13.1 (localhost, > ID:115.98.154.104.bc.googleusercontent.com-38646-1517527683931-0:3) is > shutting down > Feb 01, 2018 11:28:38 PM org.apache.activemq.broker.TransportConnector stop > INFO: Connector mqtt://localhost:54229 stopped > Feb 01, 2018 11:28:38 PM org.apache.activemq.broker.BrokerService stop > INFO: Apache ActiveMQ 5.13.1 (localhost, > ID:115.98.154.104.bc.googleusercontent.com-38646-1517527683931-0:3) uptime > 2.709 seconds > Feb 01, 2018 11:28:38 PM org.apache.activemq.broker.BrokerService stop > INFO: Apache ActiveMQ 5.13.1 (localhost, > ID:115.98.154.104.bc.googleusercontent.com-38646-1517527683931-0:3) is > shutdown > Feb 01, 2018 11:28:38 PM org.apache.beam.sdk.io.mqtt.MqttIOTest startBroker > INFO: Finding free network port > Feb 01, 2018 11:28:38 PM org.apache.beam.sdk.io.mqtt.MqttIOTest startBroker > INFO: Starting ActiveMQ brokerService on 53109 > Feb 01, 2018 11:28:38 PM org.apache.activemq.broker.BrokerService > doStartPersistenceAdapter > INFO: Using Persistence Adapter: MemoryPersistenceAdapter > Feb 01, 2018 11:28:38 PM org.apache.activemq.broker.BrokerService > doStartBroker > INFO: Apache ActiveMQ 5.13.1 (localhost, > ID:115.98.154.104.bc.googleusercontent.com-38646-1517527683931-0:4) is > starting > Feb 01, 2018 11:28:38 PM > org.apache.activemq.transport.TransportServerThreadSupport doStart > INFO: Listening for connections at: mqtt://localhost:53109 > Feb 01, 2018 11:28:38 PM org.apache.activemq.broker.TransportConnector start > INFO: Connector mqtt://localhost:53109 started > Feb 01, 2018 11:28:38 PM org.apache.activemq.broker.BrokerService > doStartBroker > INFO: Apache ActiveMQ 5.13.1 (localhost, > ID:115.98.154.104.bc.googleusercontent.com-38646-1517527683931-0:4) started > Feb 01, 2018 11:28:38 PM org.apache.activemq.broker.BrokerService > doStartBroker > INFO: For help or more information please see: http://activemq.apache.org > Feb 01, 2018 11:28:39 PM org.apache.beam.sdk.io.mqtt.MqttIOTest > lambda$testReadNoClientId$0 > INFO: Waiting pipeline connected to the MQTT broker before sending messages > ... > Feb 01, 2018 11:29:38 PM org.apache.activemq.broker.BrokerService stop > INFO: Apache ActiveMQ 5.13.1 (localhost, > ID:115.98.154.104.bc.googleusercontent.com-38646-1517527683931-0:4) is > shutting down > Feb 01, 2018 11:29:38 PM > org.apache.activemq.transport.tcp.TcpTransportServer$2 run > INFO: socketQueue interrupted - stopping > Feb 01, 2018 11:29:38 PM org.apache.activemq.broker.TransportConnector$1 > onAcceptError > SEVERE: Could not accept connection : java.lang.InterruptedException > Feb 01, 2018 11:29:38 PM org.apache.activemq.broker.TransportConnector stop > INFO: Connector mqtt://localhost:53109 stopped > Feb 01, 2018 11:29:38 PM org.apache.activemq.broker.BrokerService stop > INFO: Apache ActiveMQ 5.13.1 (localhost, > ID:115.98.154.104.bc.googleusercontent.com-38646-1517527683931-0:4) uptime 1 > minute > Feb 01, 2018 11:29:38 PM org.apache.activemq.broker.BrokerService stop > INFO: Apache ActiveMQ 5.13.1 (localhost, > ID:115.98.154.104.bc.googleusercontent.com-38646-1517527683931-0:4) is > shutdown > {code} > -- This message was sent by Atlassian JIRA (v7.6.3#76005)