@@ -47,11 +47,7 @@ object LogReplicationDuringSnapshotSyncSpecConfig extends MultiNodeConfig {
4747 raft-actor-auto-start.number-of-actors = 1
4848
4949 sharding {
50- // Sharding will be available as possible quick.
51- retry-interval = 500ms
52- waiting-for-state-timeout = 500ms
53- updating-state-timeout = 500ms
54-
50+ // drop old messages actively
5551 buffer-size = 50
5652 }
5753 compaction {
@@ -65,6 +61,16 @@ object LogReplicationDuringSnapshotSyncSpecConfig extends MultiNodeConfig {
6561 akka.testconductor.barrier-timeout = 5m
6662 // This spec don't use the eventsourced feature
6763 lerna.akka.entityreplication.raft.eventsourced.commit-log-store.retry.attempts = 0
64+
65+ akka.cluster.sharding {
66+ // Sharding will be available as possible quick.
67+ retry-interval = 500ms
68+ waiting-for-state-timeout = 500ms
69+ updating-state-timeout = 500ms
70+ distributed-data.majority-min-cap = 2
71+ coordinator-state.write-majority-plus = 0
72+ coordinator-state.read-majority-plus = 0
73+ }
6874 """
6975 }
7076
@@ -202,7 +208,7 @@ class LogReplicationDuringSnapshotSyncSpec
202208 " LogReplicationDuringSnapshotSyncSpec" should {
203209
204210 " elect node1 as a leader" in {
205- newCluster(controller, node1, node2, node3)
211+ newCluster(node1, node2, node3)
206212 runOn(node1) {
207213 expectNewLeaderElected {
208214 clusterReplication.init(Register (typedSystem))
0 commit comments