Commit graph

25342 commits

Author SHA1 Message Date
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
Patrik Nordwall
aa4a0dbcbb
clearAll when creating new EventSourcedBehaviorTestKit, #29609 (#29634)
* issue could be reproduced with sleep(200) before the persistenceTestKit.clearByPersistenceId
  in EventSourcedBehaviorTestKitImpl
* problem is that there is a race condition betwen that clear and that the EventSourcedBehavior
  is starting concurrently, which can result in that the EventSourcedBehavior may see events from
  previous test if using same persistenceId
* solution is to clearAll before starting the EventSourcedBehavior
2020-09-21 14:28:38 +02:00
Johan Andrén
cadab9388f
Cluster aware shard allocation and rolling updates (#29548)
Adds some level of cluster awareness to both the LeastShardAllocationStrategy implementations:

* #27368 prefer shard allocations on new nodes during rolling updates
* #27367 don't rebalance during rolling update
* #29554 don't rebalance when there are joining nodes
* #29553 don't allocate to leaving, downed, exiting and unreachable nodes
* When allocating when there are joining, unreachable, are leaving are de-prioritized to decrease the risk that a shard is allocated just to directly need to be re-allocated on a different node.
2020-09-21 14:13:32 +02:00
Patrik Nordwall
f5b16bfe2e
Merge pull request #29617 from YikSanChan/fix/comment-index
Fix comment index
2020-09-21 11:42:46 +02:00
Patrik Nordwall
b15baca3e6
Merge pull request #29622 from YikSanChan/cleanup/remove-redundant-brackets
Remove redundant brackets
2020-09-21 11:41:55 +02:00
Patrik Nordwall
45b955850c
Merge pull request #29618 from YikSanChan/fix/tiny
Tiny style fix
2020-09-21 11:37:23 +02:00
Patrik Nordwall
74efd34b93
Merge pull request #29621 from YikSanChan/cleanup/remove-unreferenced-private-method
Remove unreferenced private method
2020-09-21 11:35:44 +02:00
Yik San Chan
861303c768 Remove redundant brackets 2020-09-17 20:45:03 -07:00
Yik San Chan
2c164820a4 Remove unreferenced private method 2020-09-17 20:13:07 -07:00
Yik San Chan
11694f065d Replace to with toSet 2020-09-17 18:39:42 -07:00
Yik San Chan
82361c0694 Tiny style fix 2020-09-17 18:33:41 -07:00
Yik San Chan
ddf1a02d4f Fix comment index 2020-09-17 18:24:16 -07:00
Patrik Nordwall
58ca04ec70
Merge pull request #29610 from YikSanChan/echan/remove-redundant-final
remove redundant final in object private def
2020-09-17 15:57:30 +02:00
Johan Andrén
e3dadd981f
Handle SubSource already timed out on failure or completion #29095 (#29605) 2020-09-17 08:37:02 +02:00
Ignasi Marimon-Clos
5ea4c1751c
Terminates actor systems in parallel (#29606) 2020-09-16 13:33:48 +02:00
Ignasi Marimon-Clos
ffc4235980
Adds mapAsync(Unordered) operator samples (#29600) 2020-09-16 12:24:49 +02:00
Evan Chan
1d759d2a3f remove redundant final in object private def 2020-09-15 17:43:09 -07:00
Johannes Rudolph
8732b69446
testkit: more resilient check for available loopback addresses in SocketUtil on MacOS (#29607)
Fixes #29604
2020-09-15 11:22:27 +02:00
Patrik Nordwall
36d924b151
Increase stable-after in StressSpec, #29512 (#29603) 2020-09-15 11:16:01 +02:00
Patrik Nordwall
a61b4868e0
reduce too verbose logging sharding, #27276 (#29590)
Such as:
* the forward message log in the region
* logging of full state in the coordinator
2020-09-14 16:26:59 +02:00
yiksanchan
c67251ff4d
Fix markdown link with brackets (#29594) 2020-09-14 16:26:34 +02:00
yiksanchan
10641df346
Fix grammar (#29593) 2020-09-14 16:25:33 +02:00
yiksanchan
2ecad79627
Fix grammar 2020-09-13 18:31:53 -07:00
Upapan Vongkiatkachorn
51e32412d8
Adding missing word to Split Brain Resolver documentation (#29582) 2020-09-11 13:32:47 +02:00
Patrik Nordwall
cd80a26859
Merge pull request #29583 from akka/wip-res-video-patriknw
Link to Replicated Event Sourcing video
2020-09-11 08:50:48 +02:00
Patrik Nordwall
f0b3c9089b
Holistic shard allocation strategy, #29543 (#29555)
* The rebalance in the LeastShardAllocationStrategy is only comparing the region
  with most shards with the one with least shards. Makes the rebalance rather
  slow. By default it's only rebalancing 1 shard at a time.
* This new strategy looks at all current allocations to find the optimal
  number of shards per region and tries to adjust towards that value.
  Picking from all regions with more shards than the optimal.
* Absolute and relative limit on how many shards that can be rebalanced
  in one round.
* It's also not starting a new rebalance round until the previous has
  completed.
* unit tests
* second phase for fine grained rebalance, due to rounding it will not be perfect in the first phase
* randomized unit test
* configuration settings
* docs
2020-09-11 08:49:45 +02:00
Patrik Nordwall
1b4e6c2d30
Merge pull request #29584 from akka/wip-mima-2.6.9-patriknw
move mima filter to right version
2020-09-10 18:25:49 +02:00
Patrik Nordwall
6384d0a242 move mima filter to right version 2020-09-10 17:35:44 +02:00
Patrik Nordwall
11673749e4 Link to Replicated Event Sourcing video 2020-09-10 15:17:14 +02:00
Patrik Nordwall
42223eb71a
Add app-version to the Member information, #27300 (#29546)
* will be used in rolling update features
* configured with akka.cluster.app-version
* reusing same implementation as ManifestInfo.Version
  by moving that to akka.util.Version
* additional version test
* support dynver format, + separator, and commit number
* improve version parser
* lazy parse
* make Member.appVersion internal
2020-09-10 10:42:03 +02:00