=doc Fix typos in Distributed Data section (#24164)
* =doc receiveUpdateResoponse typo * =doc and -> an typo
This commit is contained in:
parent
dbe30bd91e
commit
0a77e79bf3
2 changed files with 3 additions and 3 deletions
|
|
@ -710,7 +710,7 @@ durable entry if the data could not be stored for some reason. When enabling `wr
|
||||||
such errors will only be logged and `UpdateSuccess` will still be the reply to the `Update`.
|
such errors will only be logged and `UpdateSuccess` will still be the reply to the `Update`.
|
||||||
|
|
||||||
There is one important caveat when it comes pruning of [CRDT Garbage](#crdt-garbage) for durable data.
|
There is one important caveat when it comes pruning of [CRDT Garbage](#crdt-garbage) for durable data.
|
||||||
If and old data entry that was never pruned is injected and merged with existing data after
|
If an old data entry that was never pruned is injected and merged with existing data after
|
||||||
that the pruning markers have been removed the value will not be correct. The time-to-live
|
that the pruning markers have been removed the value will not be correct. The time-to-live
|
||||||
of the markers is defined by configuration
|
of the markers is defined by configuration
|
||||||
`akka.cluster.distributed-data.durable.remove-pruning-marker-after` and is in the magnitude of days.
|
`akka.cluster.distributed-data.durable.remove-pruning-marker-after` and is in the magnitude of days.
|
||||||
|
|
|
||||||
|
|
@ -47,7 +47,7 @@ public class DataBot extends AbstractActor {
|
||||||
return receiveBuilder()
|
return receiveBuilder()
|
||||||
.match(String.class, a -> a.equals(TICK), a -> receiveTick())
|
.match(String.class, a -> a.equals(TICK), a -> receiveTick())
|
||||||
.match(Changed.class, c -> c.key().equals(dataKey), c -> receiveChanged((Changed<ORSet<String>>) c))
|
.match(Changed.class, c -> c.key().equals(dataKey), c -> receiveChanged((Changed<ORSet<String>>) c))
|
||||||
.match(UpdateResponse.class, r -> receiveUpdateResoponse())
|
.match(UpdateResponse.class, r -> receiveUpdateResponse())
|
||||||
.build();
|
.build();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
@ -81,7 +81,7 @@ public class DataBot extends AbstractActor {
|
||||||
log.info("Current elements: {}", data.getElements());
|
log.info("Current elements: {}", data.getElements());
|
||||||
}
|
}
|
||||||
|
|
||||||
private void receiveUpdateResoponse() {
|
private void receiveUpdateResponse() {
|
||||||
// ignore
|
// ignore
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue