Commit graph

25371 commits

Author SHA1 Message Date
Arnout Engelen
126d3c8ff8
Fix population of akka-protobuf-v3 (#29719)
* Fix population of akka-protobuf-v3
* Avoid automatically updating sbt-osgi
2020-10-08 13:33:20 +02:00
Renato Cavalcanti
2f2076a80d
ShardRegion ignores HostShard when shutting down (#29707) 2020-10-07 21:01:53 +02:00
Johan Andrén
d36fc8f549
Handle when there are no known regions yet #29709 2020-10-07 16:29:39 +02:00
Scala Steward
b42cc8b4cf
Update sbt-osgi to 0.9.6 (#29699) 2020-10-07 16:04:27 +02:00
Arnout Engelen
93fc7e9fa3
Update scalatest to 3.1.4 and within 3.1 (#29503) 2020-10-05 17:33:37 +02:00
Renato Cavalcanti
d866fa3f1a
Fix Welcome/Gossip deserialization of app-version (#29692) 2020-10-05 16:09:32 +02:00
Patrik Nordwall
309326fcfa
consistently prefix sharding log messages with typeName (#29682)
* we already had it in the ShardRegion
* it's possible to see it from the actor path but that might not be
  obvious and many forget to configure their logback to show the akkaSource
* fix test
2020-10-05 12:27:01 +02:00
Patrik Nordwall
1bf012837c
disseminate downing decisions faster, #29612 (#29640)
* when SBR downs the reachable side (minority) it's important
  to quickly inform everybody to shutdown
* send gossip directly to downed node, STONITH signal
* gossip to a few random immediatly when self is downed, which
  is always the last from the SBR downing
* enable gossip speedup when there are downed members
* adjust StressSpect to normal again
* adjust TransitionSpect to the new behavior
2020-10-05 11:10:06 +02:00
Stefano Baghino
190d2b6a62
shutdown it down -> shut it down (#29686) 2020-10-05 09:18:25 +02:00
Adrian
1b5f49d0b0
Support throwing exception in Java TestProbe.awaitAssert #29677 2020-10-05 09:17:39 +02:00
r-glyde
a4acf23d05
Restart(Source|Flow|Sink): Configurable stream restart deadline (#29591) 2020-10-05 09:12:15 +02:00
Muskan Gupta
4cc3c58a08
Making docs better (#29623)
Co-authored-by: Arnout Engelen <github@bzzt.net>
2020-10-02 16:30:05 +02:00
Seth Tisue
9aff46947e
upgrade ScalaTest, scalatestplus-junit, scalatestplus-mockito (#29688) 2020-10-02 09:22:00 +02:00
Josep Prat
58b1c30c6c
Make Rejected extend OperationResult (#29678)
To keep consistency with the documentation and the styleguide
`Rejected` case class should extend `OperationResult`
2020-09-30 13:39:02 +02:00
Patrik Nordwall
90b79144e5
Documentation for Sharding rolling update (#29666) 2020-09-30 12:31:03 +02:00
Patrik Nordwall
2caa560aab
Config for when to move to WeaklyUp (#29665)
* Config for when to move to WeaklyUp

* noticed when I was testing with the StressSpec that it's often moving nodes to WeaklyUp
  in normal joining scenarios (also seen in Kubernetes testing)
* better to wait some longer since the WeaklyUp will require a new convergence round
  and making the full joining -> up take longer time
* changed existing config property to be a duration
* default 7s, previously it was 3s

* on => 7s
2020-09-30 09:54:31 +02:00
Muskan Gupta
94d62f34c1
Add completion timeout example (#29673)
* Adding example for completionTimeout

* Adding header to file

* Modifying example

* Modifying duration

* Modifying syntax for duration
2020-09-29 15:47:36 +02:00
Renato Cavalcanti
289f665445
Make a distinction between hand-offs for rebalance and region shutdown (#29579) 2020-09-29 12:54:54 +02:00
Renato Cavalcanti
294c534d15
Fix links to Microsoft CQRS and ES reference (#29596) 2020-09-29 08:35:53 +02:00
Johan Andrén
5d279b6c9c
Proper threadsafe collection of stream snapshots, ignoring stopping streams. #28960 2020-09-28 17:03:50 +02:00
Johan Andrén
93a69c42ff
Watching an actor ref on a member triggers termination message #29628 2020-09-28 16:57:31 +02:00
Johan Andrén
a05712dff7
Fix for ReplicatedShardingSpec failing #29674 2020-09-28 16:33:21 +02:00
Christopher Batey
7a0e1a63d9
Filter out messages from other replicated entities #29649 2020-09-25 18:43:35 +02:00
Christopher Batey
50924e56ac
Merge pull request #29502 from chbatey/reintroduce-flush-on-terminate
Reintroduce flush on terminate
2020-09-25 16:14:56 +01:00
Christopher Batey
de1966c8a9 Disable death watch flush for remoting and fix race in rebalance worker 2020-09-25 14:39:27 +01:00
Patrik Nordwall
8e2073a6a1 Flush messages before DeathWatchNotification, #28695 (#28940)
* Since DeathWatchNotification is sent over the control channel it may overtake
  other messages that have been sent from the same actor before it stopped.
* It can be confusing that Terminated can't be used as an end-of-conversation marker.
* In classic Remoting we didn't have this problem because all messages were sent over
  the same connection.

* don't send DeathWatchNotification when system is terminating
* when using Cluster we can rely on that the other side will publish AddressTerminated
  when the member has been removed
* it's actually already a race condition that often will result in that the DeathWatchNotification
  from the terminating side
  * in DeathWatch.scala it will remove the watchedBy when receiving AddressTerminated, and that
    may (sometimes) happen before tellWatchersWeDied

* same for Unwatch
* to avoid sending many Unwatch messages when watcher's ActorSystem is terminated
* same race exists for Unwatch as for DeathWatchNotification, if RemoteWatcher publishAddressTerminated
  before the watcher is terminated

* config for the flush timeout, and possibility to disable
2020-09-25 14:37:47 +01:00
Christopher Batey
91398cdcdd
Cluster sharding health check (#29638)
* and update akka-docs/src/main/paradox/typed/cluster-sharding.md
2020-09-25 12:55:29 +02:00
Renato Cavalcanti
90dac8dcbb
swap args when initializing *MajorityPlus classes (#29664) 2020-09-24 18:48:38 +02:00
Patrik Nordwall
14275b4997
adjust default minimum for down-all-when-unstable (#29661)
* adjust default minimum for down-all-when-unstable

* when down-all-when-unstable=on it will be >= 4 seconds
* in case stable-after is tweaked to low value such as 5 seconds
2020-09-24 15:58:14 +02:00
Patrik Nordwall
d7441fd93c
Merge pull request #29595 from YikSanChan/patch-14
Fix grammar
2020-09-24 12:53:04 +02:00
yiksanchan
74282c42d2
Remove weird char NBSP (#29620)
* Remove weird char NBSP

* cr comment
2020-09-24 12:44:51 +02:00
Patrik Nordwall
e3df915da9
Merge pull request #29650 from akka/wip-eventsByPersistenceId-patriknw
use PersistenceTestKitReadJournal in EventSourcedBehaviorTestKit
2020-09-24 09:50:15 +02:00
Scala Steward
2c2cb4ecd5
Update commons-codec to 1.15 (#29653)
Co-authored-by: Arnout Engelen <arnout@bzzt.net>
2020-09-24 09:49:30 +02:00
Scala Steward
78d81de709
Update aeron-client, aeron-driver to 1.30.0 (#29655)
* Update aeron-client, aeron-driver to 1.30.0

* Upgrade to agrona 1.7.2, to keep in line with aeron

Co-authored-by: Christopher Batey <christopher.batey@gmail.com>
2020-09-24 09:47:37 +02:00
Patrik Nordwall
51045a295b
harden ReliableDeliverySpec, #29340 (#29643)
* "allow replacement of destination" failed because
  new ConsumerController is started before previous had been fully terminated
2020-09-23 13:56:35 +02:00
Scala Steward
84278bd6d9
Update commons-io to 2.8.0 (#29654) 2020-09-23 10:47:08 +02:00
Scala Steward
375814ce6b
Update jctools-core to 3.1.0 (#29656) 2020-09-23 10:46:11 +02:00
Scala Steward
05a46409f2
Update sbt-jmh to 0.4.0 (#29657) 2020-09-23 10:34:46 +02:00
Patrik Nordwall
1b026ec3d9
Merge pull request #29619 from YikSanChan/fix/replace-to-with-toSet
Replace to with toSet
2020-09-23 09:56:19 +02:00
Arnout Engelen
48a7306109
Fix documentation version warning for 'series' page (#29647) 2020-09-22 19:50:26 +02:00
Patrik Nordwall
d556be77b4
Fix cross-dc heartbeat interval config, #29614 (#29646) 2020-09-22 15:50:42 +02:00
Muskan Gupta
a12867b8b1
Docs: Reduce operator (#29641)
Co-authored-by: Arnout Engelen <github@bzzt.net>
2020-09-22 15:28:35 +02:00
Patrik Nordwall
3b0c9e971d use PersistenceTestKitReadJournal in EventSourcedBehaviorTestKit 2020-09-22 14:32:02 +02:00
Patrik Nordwall
4d00f9a8e8
Include quarantine reason when ignored because unknown UID (#29645) 2020-09-22 14:00:28 +02:00
Patrik Nordwall
31ba95dfa3
log transport flush timeout (#29644) 2020-09-22 13:57:06 +02:00
Christopher Batey
306cf65863
Docs for which versions support RES (#29642) 2020-09-22 12:24:50 +02:00
Muskan Gupta
ac648a5940
Adding example of fold for sink #25468 2020-09-21 18:01:14 +02:00
Patrik Nordwall
b7640c3261
another merge test for GCounter, #29616 (#29624) 2020-09-21 16:36:42 +02:00
Patrik Nordwall
8c0d81a374
support async reply and noReply in EventSourcedBehaviorTestKit, #29602 #29581 2020-09-21 16:35:19 +02:00
Patrik Nordwall
b28d77b316
simplify the SBR instability check (#29625) 2020-09-21 16:34:21 +02:00