failed: EdgeReplicationJavaDSLIntegrationSpec #1291

pvlugter · 2025-01-10T01:37:03Z

[info] - should replicate concurrent writes to the other DCs *** FAILED *** (20 seconds, 32 milliseconds)
[info]   Greeting 2 for entity id p-22 Set("hello 2 from DCD", "hello 2 from DCC") had size 2 instead of expected size 1 (EdgeReplicationJavaDSLIntegrationSpec.scala:391)
[info]   org.scalatest.exceptions.TestFailedException:
[info]   at org.scalatest.matchers.MatchersHelper$.indicateFailure(MatchersHelper.scala:392)
[info]   at org.scalatest.matchers.should.Matchers$ResultOfHaveWordForExtent.size(Matchers.scala:2805)
[info]   at akka.projection.grpc.replication.EdgeReplicationJavaDSLIntegrationSpec.$anonfun$new$40(EdgeReplicationJavaDSLIntegrationSpec.scala:391)
[info]   at org.scalatest.Assertions.withClue(Assertions.scala:1065)
[info]   at org.scalatest.Assertions.withClue$(Assertions.scala:1052)
[info]   at akka.actor.testkit.typed.scaladsl.ScalaTestWithActorTestKit.withClue(ScalaTestWithActorTestKit.scala:31)
[info]   at akka.projection.grpc.replication.EdgeReplicationJavaDSLIntegrationSpec.$anonfun$new$39(EdgeReplicationJavaDSLIntegrationSpec.scala:391)
[info]   at scala.collection.immutable.Set$Set3.foreach(Set.scala:261)
[info]   at akka.projection.grpc.replication.EdgeReplicationJavaDSLIntegrationSpec.$anonfun$new$38(EdgeReplicationJavaDSLIntegrationSpec.scala:380)
[info]   at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.scala:18)
[info]   at akka.actor.testkit.typed.internal.TestProbeImpl.poll$1(TestProbeImpl.scala:374)
[info]   at akka.actor.testkit.typed.internal.TestProbeImpl.awaitAssert_internal(TestProbeImpl.scala:391)
[info]   at akka.actor.testkit.typed.internal.TestProbeImpl.awaitAssert(TestProbeImpl.scala:350)
[info]   at akka.projection.grpc.replication.EdgeReplicationJavaDSLIntegrationSpec.$anonfun$new$33(EdgeReplicationJavaDSLIntegrationSpec.scala:395)
[info]   at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.scala:18)
[info]   at org.scalatest.Assertions.withClue(Assertions.scala:1065)
[info]   at org.scalatest.Assertions.withClue$(Assertions.scala:1052)
[info]   at akka.actor.testkit.typed.scaladsl.ScalaTestWithActorTestKit.withClue(ScalaTestWithActorTestKit.scala:31)
[info]   at akka.projection.grpc.replication.EdgeReplicationJavaDSLIntegrationSpec.$anonfun$new$32(EdgeReplicationJavaDSLIntegrationSpec.scala:359)
[info]   at scala.collection.immutable.Range.foreach$mVc$sp(Range.scala:190)
[info]   at akka.projection.grpc.replication.EdgeReplicationJavaDSLIntegrationSpec.$anonfun$new$31(EdgeReplicationJavaDSLIntegrationSpec.scala:358)

https://github.com/akka/akka-projection/actions/runs/12700308434/job/35402706136#step:6:7166

The text was updated successfully, but these errors were encountered:

pvlugter · 2025-01-10T01:37:15Z

https://github.com/akka/akka-projection/actions/runs/12700232554/job/35402484756#step:6:7137

pvlugter · 2025-01-10T01:38:26Z

[info] - should replicate writes from one dc to the other DCs *** FAILED *** (11 seconds, 878 milliseconds)
[info]   from DCD on EdgeReplicationIntegrationJavaSpecA for entity id p-22 "hello 1 from DCC" did not equal "hello 1 from DCD" (EdgeReplicationJavaDSLIntegrationSpec.scala:348)

https://github.com/akka/akka-projection/actions/runs/12700232554/job/35402484348#step:6:4081