search

apache / pekko-connectors

Apache Pekko Connectors is a Reactive Enterprise Integration library for Java and Scala, based on Reactive Streams and Apache Pekko.
https://pekko.apache.org/
Apache License 2.0
56 stars 27 forks source link

Kudu - use slf4jv2 #622

Closed pjfanning closed 2 months ago

Roiocam commented 2 months ago

Is this a newly discovered flaky test?

[info] - should re-connect given connect, subscribe, connect again, publish *** FAILED *** (5 seconds, 12 milliseconds)
[info]   java.lang.AssertionError: assertion failed: expected no StreamSupervisor children, but got [Actor[pekko://mqtt-spec/system/Materializers/StreamSupervisor-4/flow-298-0-unnamed#-534541061], Actor[pekko://mqtt-spec/system/Materializers/StreamSupervisor-4/flow-299-0-ignoreSink#-1779770584]]
[info]   at scala.Predef$.assert(Predef.scala:279)
[info]   at org.apache.pekko.stream.testkit.scaladsl.StreamTestKit$.$anonfun$assertNoChildren$2(StreamTestKit.scala:64)
[info]   at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.scala:18)
[info]   at org.apache.pekko.testkit.TestKitBase.poll$2(TestKit.scala:342)
[info]   at org.apache.pekko.testkit.TestKitBase.awaitAssert(TestKit.scala:359)
[info]   at org.apache.pekko.testkit.TestKitBase.awaitAssert$(TestKit.scala:331)
[info]   at org.apache.pekko.testkit.TestKit.awaitAssert(TestKit.scala:982)
[info]   at org.apache.pekko.stream.testkit.scaladsl.StreamTestKit$.$anonfun$assertNoChildren$1(StreamTestKit.scala:61)
[info]   at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.scala:18)
[info]   at org.apache.pekko.testkit.TestKitBase.within(TestKit.scala:429)
pjfanning commented 2 months ago

not needed due to #626