Aaronontheweb on 1.4.16
Aaronontheweb on master
Added v1.4.16 placeholder for n… typo (#4734) Allow different versions of MS … and 2 more (compare)
Aaronontheweb on 1.4.16
Aaronontheweb on dev
Added v1.4.16 release notes (#4… (compare)
Aaronontheweb on 1.4.16
Added v1.4.16 release notes ##… (compare)
dependabot-preview[bot] on nuget
Bump System.Configuration.Confi… (compare)
dependabot-preview[bot] on nuget
Bump NUnit from 3.7.1 to 3.13.0… (compare)
@heyixiaoran looks like you're talking about two different things:
It's like difference between memory and CPU.
@Horusiath The issue happened again. Here is a dump of the data.
Ordering | PersistenceId | SequenceNr | Timestamp | IsDeleted | Manifest | Payload | Tags | SerializerId |
---|---|---|---|---|---|---|---|---|
136 | /system/sharding/customerCoordinator/singleton/coordinator | 105 | 636783291061582824 | 0 | AF | 0x0A0233361248616B6B612E7463703A2F2F696D62757273654031302E3234302E302E3130383A383038312F73797374656D2F7368617264696E672F637573746F6D65722331363635343832363933 | NULL | 13 |
140 | /system/sharding/customerCoordinator/singleton/coordinator | 106 | 636784965012362487 | 0 | AB | 0x0A47616B6B612E7463703A2F2F696D62757273654031302E3234302E302E3132323A383038312F73797374656D2F7368617264696E672F637573746F6D657223323432333036343237 | NULL | 13 |
141 | /system/sharding/customerCoordinator/singleton/coordinator | 107 | 636784965012552987 | 0 | AC | 0x0A4C616B6B612E7463703A2F2F696D62757273654031302E3234302E302E35333A383038312F73797374656D2F7368617264696E672F637573746F6D657250726F78792332313137333131313037 | NULL | 13 |
142 | /system/sharding/customerCoordinator/singleton/coordinator | 108 | 636784965012782458 | 0 | AC | 0x0A4D616B6B612E7463703A2F2F696D62757273654031302E3234302E302E3132363A383038312F73797374656D2F7368617264696E672F637573746F6D657250726F78792331323135343337333535 | NULL | 13 |
143 | /system/sharding/customerCoordinator/singleton/coordinator | 109 | 636784965126035293 | 0 | AD | 0x0A46616B6B612E7463703A2F2F696D62757273654031302E3234302E302E33303A383038312F73797374656D2F7368617264696E672F637573746F6D657223393630383739383036 | NULL | 13 |
144 | /system/sharding/customerCoordinator/singleton/coordinator | 110 | 636784965229904859 | 0 | AB | 0x0A46616B6B612E7463703A2F2F696D62757273654031302E3234302E302E31343A383038312F73797374656D2F7368617264696E672F637573746F6D657223373231343333303930 | NULL | 13 |
With the exception:
Exception in ReceiveRecover when replaying event type ["Akka.Cluster.Sharding.PersistentShardCoordinator+ShardHomeAllocated"] with sequence number [105] for persistenceId ["/system/sharding/customerCoordinator/singleton/coordinator"]
{
"Depth": 0,
"ClassName": "",
"Message": "Region [akka.tcp://imburse@10.240.0.108:8081/system/sharding/customer#1665482693] not registered\nParameter name: e",
"Source": "Akka.Cluster.Sharding",
"StackTraceString": " at Akka.Cluster.Sharding.PersistentShardCoordinator.State.Updated(IDomainEvent e)\n at Akka.Cluster.Sharding.PersistentShardCoordinator.ReceiveRecover(Object message)\n at Akka.Actor.ActorBase.AroundReceive(Receive receive, Object message)\n at Akka.Persistence.Eventsourced.<>c__DisplayClass91_0.<Recovering>b__1(Receive receive, Object message)",
"RemoteStackTraceString": "",
"RemoteStackIndex": -1,
"HResult": -2147024809,
"HelpURL": null
}
Would you like me to create this as a bug in the issue tracker?
Hi Guys, I have a question regardig FlowOps.GroupedWithin()
A small timing Diagram:
==> Time-Axis
| e e e e e e e .e e e e e e
|--------t-----|--------t.-------|--------t--------|
# . # x #
# . # x #
# |-------#t-x|--------t----#---|
# # x #
1 2 x 3
x
4
GroupedWihin emits when the amount of grouped elements reaches the defined limit, or the time since the last emitted group exceeds the defined timeout.
In my example GroupedWithin(6, t) this will emit a complete group at time 1, another partially filled group (4 elements) at time 2 and another parially filled group (2 elements) at time 3.
I need a behaviour, that emits when the amount of grouped element reaches the defined limit, or the time since the first received element of the current group exceeds the defined timeout... That would emit the first group at time 1, and the next completely filled group at time 4.
Is there such a Grouping behaviour ?
I've just tried using Akka.Quartz.Actor.QuartzActor
using Akka.System.ActorOf(Props.Create(() => new QuartzActor()), "scheduler");
in a .net core 2.1 app and got a:
[akka://System/user/scheduler#154807920]: Akka.Actor.ActorInitializationException: Exception during creation ---> System.TypeLoadException: Error while creating actor instance of type Akka.Quartz.Actor.QuartzActor with 0 args: () ---> System.Reflection.TargetInvocationException: Exception has been thrown by the target of an invocation. ---> System.IO.FileNotFoundException: Could not load file or assembly 'System.Configuration.ConfigurationManager, Version=0.0.0.0, Culture=neutral, PublicKeyToken=cc7b13ffcd2ddd51'. The system cannot find the file specified.
at Quartz.Impl.StdSchedulerFactory.Initialize()
at Quartz.Impl.StdSchedulerFactory.GetScheduler() in c:\projects\quartznet\src\Quartz\Impl\StdSchedulerFactory.cs:line 1102
at Akka.Quartz.Actor.QuartzActor..ctor()
--- End of inner exception stack trace ---
at System.RuntimeTypeHandle.CreateInstance(RuntimeType type, Boolean publicOnly, Boolean wrapExceptions, Boolean& canBeCached, RuntimeMethodHandleInternal& ctor)
at System.RuntimeType.CreateInstanceSlow(Boolean publicOnly, Boolean wrapExceptions, Boolean skipCheckThis, Boolean fillCache)
at System.Activator.CreateInstance(Type type, Boolean nonPublic, Boolean wrapExceptions)
at System.RuntimeType.CreateInstanceImpl(BindingFlags bindingAttr, Binder binder, Object[] args, CultureInfo culture, Object[] activationAttributes)
at Akka.Actor.Props.ActivatorProducer.Produce()
at Akka.Actor.Props.NewActor()
--- End of inner exception stack trace ---
at Akka.Actor.Props.NewActor()
at Akka.Actor.ActorCell.CreateNewActorInstance()
at Akka.Actor.ActorCell.<>c__DisplayClass109_0.<NewActor>b__0()
at Akka.Actor.ActorCell.UseThreadContext(Action action)
at Akka.Actor.ActorCell.NewActor()
at Akka.Actor.ActorCell.Create(Exception failure)
--- End of inner exception stack trace ---
at Akka.Actor.ActorCell.Create(Exception failure)
at Akka.Actor.ActorCell.SysMsgInvokeAll(EarliestFirstSystemMessageList messages, Int32 currentState)
any suggestions how to get rid of this? I take it, this extension is not under active development? From the initial looks of it, it seems to be targeting .NET 4.5.2 ?
Is there any gotcha's when using Cluster Discovery Consul + Routing?
Here is my deployment config:
/other {
router = broadcast-group
routees.paths = ["/user/api"]
virtual-nodes-factor = 8
cluster {
enabled = on
max-nr-of-instances-per-node = 2
allow-local-routees = off
use-role = "other"
}
}
I have the other console application running with an actor ready for messages at /user/api
Here is the cluster config:
cluster {
roles = ["other"]
}
Logs are showing that the nodes are up and running with the correct roles.
But the when telling /user/other
a message it keeps deadlettering. Anyway to debug what's going on?
NewtonSoftJsonSerializer