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