Commit graph

25511 commits

Author SHA1 Message Date
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
Christopher Batey
73f04f0a23
Update latest patch version (#29580) 2020-09-10 09:59:57 +02:00
Patrik Nordwall
7e768fa732
Merge pull request #29551 from akka/wip-29543-alloc-after-rebalance-patriknw
Allocate rebalanced shards immediately, #29543
2020-09-09 18:45:46 +02:00
Ignasi Marimon-Clos
59e6bd8651
Fix markdown syntax for link that uses parens (#29576) 2020-09-09 17:21:25 +02:00
Arnout Engelen
ca59d8149c
Enable fatal errors for docs (#29570) 2020-09-08 15:10:21 +02:00
Aleh Reishal
e0ceb71ccd
Fix calculating backoff delay in order to prevent IllegalArgumentExce… (#29569)
* Fix calculating backoff delay in order to prevent IllegalArgumentException #29568

* Fix calculating backoff delay in order to prevent IllegalArgumentException #29568 / remove BackoffCalculatorSpec due to it is difficult to make calculateDelay testable and not tp break binary backward compatibility
2020-09-08 12:38:32 +02:00
Arnout Engelen
6e71accd90
Publish releases as 'github release' as well (#29572)
To make it show up nicely in the right-side sidebar
2020-09-08 11:48:06 +02:00
Christopher Batey
6c631a65fe
Reduce sharding warnings when there are no buffered messages (#29525)
* Reduce sharding warnings when there are no buffered messages

If shard regions are started before the cluster is formed warnings are
logged. The user can wait until SelfUp but for the cases they don't make
logging debug until the user has buffered messages.

* Review feedback

* Review feedback
2020-09-08 09:17:34 +01:00
Patrik Nordwall
9074b434c2
minor doc updates for replicated event sourcing (#29561)
* also link to Projections in cqrs page
2020-09-08 08:29:28 +02:00
Johannes Rudolph
540c7205e1
testkit: do not try to use 127.x.y.255 as a test localhost address (#29566)
For some arcane reason, the JDK seems to block binding attempts to that
address.
2020-09-07 19:29:36 +02:00
Patrik Nordwall
6becd8e0ee
Merge pull request #29539 from akka/wip-27786-setDeliverySnapshot-patriknw
Fix time in AtLeastOnce.setDeliverySnapshot, #27786
2020-09-07 15:15:47 +02:00
Josep Prat
9113c07da5
Add links to how to deal with blocking APIs #29544 (#29547)
Refs: #29544
Adds a couple of links to dealing with blocking APIs
2020-09-07 14:10:08 +01:00
Patrik Nordwall
a548949143
Chunked messages in reliable delivery, #24276 (#28915)
* To avoid head of line blocking from serialization and transfer of large messages
  this can be enabled.
* ProducerController setting to chunk messages
* split up large messages in chunks in ProducerController
  and assemble again in ConsumerController
* serialization moved to these actors instead of in the Artery stream
* other messages (for other actors) can interleave with the chunks
* serializer for ChunkedMessage in SequencedMessage and MessageSent
* cleanup partially stored chunked messages
* reference docs
* mima filters
* additional test for sending the Request after half window size
* enforce that chunk-large-messages=off for sharding and work-pulling
2020-09-07 14:02:52 +02:00
Patrik Nordwall
d5bb125ae0
Merge pull request #29495 from akka/feature-active-active-event-sourcing
Replicated event sourcing
2020-09-04 10:35:21 +02:00
Patrik Nordwall
b09653c977 Allocate rebalanced shards immediately, #29543
* Otherwise it will continue to deallocate when there is no traffic
  that triggers allocations
2020-09-04 10:27:29 +02:00
Patrik Nordwall
bb985b82c6 fix compilation errors 2020-09-03 13:42:42 +02:00
Patrik Nordwall
4629cd44e4 Merge branch 'master' into feature-active-active-event-sourcing 2020-09-03 11:52:41 +02:00
mgutmanis
33fda3ae6f
Improve Shard#entityCreated API performance #29520
Expose size of reachable actor count
2020-09-02 16:49:36 +02:00
Patrik Nordwall
7bf12721c1 Merge branch 'master' into feature-active-active-event-sourcing 2020-09-02 15:46:06 +02:00
Renato Cavalcanti
32ec0428d3
Document workaround for jackson serialiaztion of scala case objects (#29531)
* workaround for jackson serialiaztion of scala case objects

* improved sentence
2020-09-02 14:19:13 +02:00
Johan Andrén
192be028a0
Sharding request-to-start but already started logging (#29545) 2020-09-02 14:18:44 +02:00
Patrik Nordwall
9b709df2d0
Fix acceptable-heartbeat-pause in cluster.StressSpec, #29512 (#29541) 2020-09-02 12:48:52 +02:00
Patrik Nordwall
cd8d5c5d08 Fix time in AtLeastOnce.setDeliverySnapshot, #27786
* to be consistent with internalDeliver when recoveryRunning
2020-09-01 12:08:05 +02:00
yiksanchan
4249b02c40
Fix grammar in exception message (#29533) 2020-09-01 10:57:15 +02:00
Patrick Altaie
99f21dba3a
Add "akka" prefix to TCK code sample (#29529)
The current code sample for trying out the TCK misses the "akka" prefix
which means that the TCK test will fail with an error regarding not
specifying a journal plugin (because the journal plugin property is
wrong in the sample)

Fixes #29528
2020-09-01 09:42:25 +02:00
Christopher Batey
7368e13458
Start ShardedDaemon pinging once member is up (#29526) 2020-08-28 15:37:04 +02:00
Josep Prat
1180b8364e
Use the correct name for Akka HTTP (#29527)
Fixes the typo in the name of Akka HTTP, it's written in lower case but the project name is in upper case.
2020-08-26 12:03:01 +02:00
Ignasi Marimon-Clos
418d6d3ec0
Prefer "update" over "upgrade" when rolling (#29523) 2020-08-25 11:11:06 +02:00
Ignasi Marimon-Clos
728dda874e
Event migration improvements (#29514) 2020-08-25 11:10:33 +02:00
Christopher Batey
2d9660f847 Final review feedback 2020-08-25 10:02:27 +01:00
Patrik Nordwall
57fb9e9093
Merge pull request #29517 from scala-steward/update/sbt-java-formatter-0.6.0
Update sbt-java-formatter to 0.6.0
2020-08-24 14:22:30 +02:00
Scala Steward
1ee9a322b6
Update sbt-reproducible-builds to 0.25 (#29305) 2020-08-24 13:20:24 +02:00