You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@pekko.apache.org by "raboof (via GitHub)" <gi...@apache.org> on 2024/02/08 12:24:16 UTC

[I] MqttSessionSpec: MQTT client connector should unsubscribe a client session test flaky [incubator-pekko-connectors]

raboof opened a new issue, #458:
URL: https://github.com/apache/incubator-pekko-connectors/issues/458

   Seems flaky:
   
   ```
   [info] MqttSessionSpec:
   [info] MQTT client connector
   [info] - should flow through a client session (56 milliseconds)
   [info] - should Connect and carry through an object to ConnAck (43 milliseconds)
   [info] - should Connect and stash any subsequent messages (48 milliseconds)
   [info] - should Connect and fail given no ack (50 milliseconds)
   [info] - should Connect successfully, subscribe and fail given no ack (54 milliseconds)
   [info] - should disconnect when connected (49 milliseconds)
   [info] - should disconnect when connection lost (47 milliseconds)
   [info] - should disconnect when connection lost while subscribing (48 milliseconds)
   [info] - should correctly handle a new client connection (50 milliseconds)
   [info] - should receive a QoS 0 publication from a subscribed topic (43 milliseconds)
   [info] - should receive a QoS 1 publication from a subscribed topic and ack it (56 milliseconds)
   [info] - should receive a QoS 1 publication from a subscribed topic and ack it and then ack it again - the stream should ignore (159 milliseconds)
   [info] - should receive a QoS 1 publication from a subscribed topic but do not ack it initially (550 milliseconds)
   [info] - should receive a QoS 1 publication with DUP indicated from a unsubscribed topic - simulates a reconnect (43 milliseconds)
   [info] - should receive a QoS 2 publication from a subscribed topic and rec and comp it (55 milliseconds)
   [info] - should publish with a QoS of 0 (41 milliseconds)
   [info] - should publish and carry through an object to pubAck (44 milliseconds)
   [info] - should publish twice with a QoS of 1 so that the second is queued (49 milliseconds)
   [info] - should publish with a QoS of 1 and cause a retry given a timeout (52 milliseconds)
   [info] - should publish with a QoS of 1 and cause a retry given a reconnect (31 milliseconds)
   [info] - should publish with QoS 2 and carry through an object to pubComp (51 milliseconds)
   [info] - should connect and send out a ping request (679 milliseconds)
   [info] - should disconnect a connected session if a ping request is not replied to (282 milliseconds)
   [info] - should unsubscribe a client session *** FAILED *** (656 milliseconds)
   [info]   A timeout occurred waiting for a future to complete. Waited 600 milliseconds. (MqttSessionSpec.scala:1245)
   [info]   org.scalatest.concurrent.ScalaFutures$$anon$2:
   [info]   at org.scalatest.concurrent.ScalaFutures$$anon$1.futureValueImpl(ScalaFutures.scala:345)
   [info]   at org.scalatest.concurrent.Futures$FutureConcept.futureValue(Futures.scala:476)
   [info]   at org.scalatest.BeforeAndAfterAll.run$(BeforeAndAfterAll.scala:135)
   [info]   at docs.scaladsl.MqttSessionSpec.run(MqttSessionSpec.scala:45)
   [info]   at org.scalatest.tools.Framework.org$scalatest$tools$Framework$$runSuite(Framework.scala:321)
   [info]   at org.scalatest.tools.Framework$ScalaTestTask.execute(Framework.scala:517)
   [info]   at sbt.TestRunner.runTest$1(TestFramework.scala:153)
   [info]   at sbt.TestRunner.run(TestFramework.scala:168)
   [info]   at sbt.TestFramework$$anon$3$$anonfun$$lessinit$greater$1.$anonfun$apply$1(TestFramework.scala:336)
   [info]   at sbt.TestFramework$.sbt$TestFramework$$withContextLoader(TestFramework.scala:296)
   [info]   at sbt.TestFramework$$anon$3$$anonfun$$lessinit$greater$1.apply(TestFramework.scala:336)
   [info]   at sbt.TestFramework$$anon$3$$anonfun$$lessinit$greater$1.apply(TestFramework.scala:336)
   [info]   at sbt.TestFunction.apply(TestFramework.scala:348)
   [info]   at sbt.Tests$.processRunnable$1(Tests.scala:475)
   [info]   at sbt.Tests$.$anonfun$makeSerial$1(Tests.scala:481)
   [info]   at sbt.std.Transform$$anon$3.$anonfun$apply$2(Transform.scala:47)
   [info]   at sbt.std.Transform$$anon$4.work(Transform.scala:69)
   [info]   at sbt.Execute.$anonfun$submit$2(Execute.scala:283)
   [info]   at sbt.internal.util.ErrorHandling$.wideConvert(ErrorHandling.scala:24)
   [info]   at sbt.Execute.work(Execute.scala:292)
   [info]   at sbt.Execute.$anonfun$submit$1(Execute.scala:283)
   [info]   at sbt.ConcurrentRestrictions$$anon$4.$anonfun$submitValid$1(ConcurrentRestrictions.scala:265)
   [info]   at sbt.CompletionService$$anon$2.call(CompletionService.scala:65)
   [info]   at java.util.concurrent.FutureTask.run(FutureTask.java:266)
   [info]   at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
   [info]   at java.util.concurrent.FutureTask.run(FutureTask.java:266)
   [info]   at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
   [info]   at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
   [info]   at java.lang.Thread.run(Thread.java:750)
   ```


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: notifications-unsubscribe@pekko.apache.org.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org


---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscribe@pekko.apache.org
For additional commands, e-mail: notifications-help@pekko.apache.org


Re: [I] MqttSessionSpec: MQTT client connector should unsubscribe a client session test flaky [incubator-pekko-connectors]

Posted by "raboof (via GitHub)" <gi...@apache.org>.
raboof closed issue #458: MqttSessionSpec: MQTT client connector should unsubscribe a client session test flaky
URL: https://github.com/apache/incubator-pekko-connectors/issues/458


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: notifications-unsubscribe@pekko.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org


---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscribe@pekko.apache.org
For additional commands, e-mail: notifications-help@pekko.apache.org


Re: [I] MqttSessionSpec: MQTT client connector should unsubscribe a client session test flaky [incubator-pekko-connectors]

Posted by "raboof (via GitHub)" <gi...@apache.org>.
raboof closed issue #458: MqttSessionSpec: MQTT client connector should unsubscribe a client session test flaky
URL: https://github.com/apache/incubator-pekko-connectors/issues/458


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: notifications-unsubscribe@pekko.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org


---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscribe@pekko.apache.org
For additional commands, e-mail: notifications-help@pekko.apache.org