[ https://issues.apache.org/jira/browse/IGNITE-2255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Semen Boikov updated IGNITE-2255: --------------------------------- Assignee: Yakov Zhdanov > IgniteMqttStreamerTest.testConnectionStatusWithBrokerDisconnection fails > ------------------------------------------------------------------------ > > Key: IGNITE-2255 > URL: https://issues.apache.org/jira/browse/IGNITE-2255 > Project: Ignite > Issue Type: Bug > Components: streaming > Reporter: Semen Boikov > Assignee: Yakov Zhdanov > > Test IgniteMqttStreamerTest.testConnectionStatusWithBrokerDisconnection fails > sometimes on TC. Also was able to reproduce locally. > Sometimes fails assert 'assertTrue(streamer.isConnected());', > Also locally got hang at test stop: > {noformat} > "main" prio=6 tid=0x0000000001fca800 nid=0xd6c in Object.wait() > [0x000000000238e000] > java.lang.Thread.State: WAITING (on object monitor) > at java.lang.Object.wait(Native Method) > - waiting on <0x00000007d75bedb0> (a java.lang.Object) > at java.lang.Object.wait(Object.java:503) > at > org.eclipse.paho.client.mqttv3.internal.Token.waitForResponse(Token.java:141) > - locked <0x00000007d75bedb0> (a java.lang.Object) > at > org.eclipse.paho.client.mqttv3.internal.Token.waitForCompletion(Token.java:108) > at > org.eclipse.paho.client.mqttv3.MqttToken.waitForCompletion(MqttToken.java:63) > at > org.eclipse.paho.client.mqttv3.MqttClient.disconnect(MqttClient.java:254) > at > org.apache.ignite.stream.mqtt.MqttStreamer.stop(MqttStreamer.java:280) > at > org.apache.ignite.stream.mqtt.IgniteMqttStreamerTest.afterTest(IgniteMqttStreamerTest.java:159) > at > org.apache.ignite.testframework.junits.GridAbstractTest.tearDown(GridAbstractTest.java:1362) > at > org.apache.ignite.testframework.junits.common.GridCommonAbstractTest.tearDown(GridCommonAbstractTest.java:391) > {noformat} -- This message was sent by Atlassian JIRA (v6.3.4#6332)