t; It should just work. akka-slf4j redirects Akka log event stream to slf4j
> so log entries from akka.event.LoggingAdapter and org.slf4j.Logger will
> end in the same backend.
>
> Cheers,
> Rafał
>
> W dniu czwartek, 2 lutego 2017 01:15:17 UTC+1 użytkownik Dai Yinhua
> na
Hi team,
What is the graceful method to shutdown akka cluster?
If I have an akka cluster with 20 nodes and each nodes starts 3 jvm process
for actorsystem.
How can I gracefully shutdown the whole cluster for upgrading.
Thank you.
--
>> Read the docs: http://akka.io/docs/
Hi team,
Do you ever used the akka persistent
redis: https://index.scala-lang.org/hootsuite/akka-persistence-redis?
Why I can't get the repository from maven central?
--
>> Read the docs: http://akka.io/docs/
>> Check the FAQ:
>>
;
> Note, there is a bug in M1 which makes the sigterm part not working.
>
> /Patrik
> lör 4 feb. 2017 kl. 16:58 skrev Dai Yinhua <yhdai...@gmail.com
> >:
>
>> Hi team,
>>
>> What is the graceful method to shutdown akka cluster?
>> If I ha
Hi team,
I am using cluster sharding function, and it's working.
But after I added *min-nr-of-members = 3* to my application.conf, the
sharding function is not working, and when I using shardregion.tell I get
below error messages:
[WARN ] 02:09:20.448UTC
hu, Jan 19, 2017 at 10:15 AM, Dai Yinhua <yhdai...@gmail.com
> > wrote:
>
>> Any suggestion please?
>>
>>
>> On Wednesday, 18 January 2017 09:36:35 UTC+8, Dai Yinhua wrote:
>>>
>>> 2.4.12, by the way, this happened when I debug from eclipse
&g
Hi team,
I'm using cluster sharding to process request from client.
My entity actor is actually some factory actor, which means it will create
different actors based on the request parameters, and I will set a name for
each actor.
Example code as below:
Awesome, I will try it, thank you.
On Sunday, 19 February 2017 02:04:31 UTC+8, Steve Song wrote:
>
> We released v0.7 today that supports Scala 2.12 and Akka 2.4.12. Let me
> know if you run into issues with the release.
>
> Steve
>
> On Tuesday, February 14, 2017 at 1
resolver. Have you added that to your sbt file?
>
> On Wed, Feb 8, 2017 at 9:54 PM, Dai Yinhua <yhdai...@gmail.com
> > wrote:
>
>> Hi team,
>>
>> Do you ever used the akka persistent redis:
>> https://index.scala-lang.org/hootsuite/akka-persistence-redis?
>
Thank you Vadim, you solved my question.
On Saturday, 11 February 2017 01:02:11 UTC+8, Vadim Chelyshov wrote:
>
> It does not published in maven central.
> I should add jcenter repository in yours build defenition.
>
> 2017-02-10 17:53 GMT+03:00 Dai Yinhua <yhdai...@gmail.com
Thank you Vadim, you solved my problem.
On Saturday, 11 February 2017 01:02:11 UTC+8, Vadim Chelyshov wrote:
>
> It does not published in maven central.
> I should add jcenter repository in yours build defenition.
>
> 2017-02-10 17:53 GMT+03:00 Dai Yinhua <yhdai...@gmail.com
ave to think about what we
> should do about it. At least it should be documented, and maybe it would be
> better with a separate property for this than using the same as the
> cluster.min-nr-of-members?
>
> /Patrik
>
> On Fri, Feb 10, 2017 at 3:56 PM, Dai Yinhua <yhd
Hi team,
Is any one using akka-persistence-redis, I have encountered below exception
when I was trying to use akka-persistence-redis 0.6.
Uncaught error from thread
[RTAPCluster-akka.persistence.dispatchers.default-plugin-dispatcher-17]
shutting down JVM since 'akka.jvm-exit-on-fatal-error'
Hi Patrik,
Get it, thank you for your response.
--
>> Read the docs: http://akka.io/docs/
>> Check the FAQ:
>> http://doc.akka.io/docs/akka/current/additional/faq.html
>> Search the archives: https://groups.google.com/group/akka-user
---
You
>
> Hi Julien,
>>
>
Yes, I think below is the corresponding maven format.
com.hootsuite
akka-persistence-redis_2.11
0.6.0
But I can't find it from https://repo1.maven.org/maven2/
--
>> Read the docs: http://akka.io/docs/
>> Check the FAQ:
>>
Hi Patrik,
>
>
Two of them using ClusterSharding.get(m_actorSystem).start
One of them using ClusterSharding.get(m_actorSystem).startProxy
So actually I want one as an endpoint, and two servers act as worker node.
Is that the reason?
--
>> Read the docs: http://akka.io/docs/
Any suggestion please?
On Wednesday, 18 January 2017 09:36:35 UTC+8, Dai Yinhua wrote:
>
> 2.4.12, by the way, this happened when I debug from eclipse
>
> On Tuesday, 17 January 2017 14:06:36 UTC+8, Patrik Nordwall wrote:
>>
>> Akka version?
>>
>>>
>&
2.4.12, by the way, this happened when I debug from eclipse
On Tuesday, 17 January 2017 14:06:36 UTC+8, Patrik Nordwall wrote:
>
> Akka version?
>
>>
>>
--
>> Read the docs: http://akka.io/docs/
>> Check the FAQ:
>>
2.4.12, by the way, this happened when I debug from eclipse
On Tuesday, 17 January 2017 14:06:36 UTC+8, Patrik Nordwall wrote:
>
> Akka version?
>
> tis 17 jan. 2017 kl. 02:53 skrev Dai Yinhua <yhdai...@gmail.com
> >:
>
>> Hi,
>>
>> I was running
Hi,
I was running a akka cluster, but when I start only one instance of the
akka application, then it will throw below exception repeatedly, can you
help to explain what is the issue and how to avoid it.
[ERROR] [01/17/2017 07:54:57.033]
[RTAPCluster-akka.actor.default-dispatcher-12]
Hi Akka team,
I am developing an application with cluster sharding.
And I have below deployment:
server1(3 jvms): seed 1, seed 2, endpoint
server2(2 jvms): worker 1, worker 2
server3(2 jvms): worker 1, worker 2
The seed instance will act only the role of seed, no shard region is
started.
The
Hi team,
I encountered a jvm crash when akka try to process mailbox.
Here is the stack, it seems that the issue happened on kryo? It doesn't
always happen, I haven't get a reproduce pattern.
Is that indicate an issue of kryo?
Where can I start to investigate the issue?
Thank you.
j
Hi Guys,
I plan to build up an calculation cluster using cluster sharding, and I
have some c++ client will send request to the cluster.
The hard part is I have to use an internal library to send request and
receive result, the internal library is build on top of TCP in java, and
probably will
necessary to load snapshots.
>
> shared-leveldb-journal is only intended for testing, but also for that
> purpose I would recommend using something real such as
> akka-persistence-cassandra.
>
> /Patrik
>
> On Thu, Jan 5, 2017 at 9:34 AM, Dai Yinhua <yhdai...@gmail.com
&
As the title, I tried to use Keylord to read the content of the .ldb file,
but it failed, I would like to know what content is persisted.
Thanks.
--
>> Read the docs: http://akka.io/docs/
>> Check the FAQ:
>>
Hi Guys,
I'm learning Akka cluster sharding with shared leveldb plugin.
Here is my config:
persistence {
journal.plugin = "akka.persistence.journal.leveldb-shared"
journal.leveldb-shared.store {
# DO NOT USE 'native = off' IN PRODUCTION !!!
native = off
OK, it make sense to me now, thank you.
On Friday, 6 January 2017 19:38:10 UTC+8, Patrik Nordwall wrote:
>
>
>
> On Fri, Jan 6, 2017 at 2:57 AM, Dai Yinhua <yhdai...@gmail.com
> > wrote:
>
>> Hi Patrik,
>>
>> From Akka documentation, "Note that
Hi Guys,
I'm writing an distributed application with AKKA cluster sharding, my
system will expose websocket protocol to external system, so it's a
streaming system.
I'm wondering what is the best practice to upgrade my AKKA application.
For example, if my entity actor needs to be upgrade, do I
day, 6 January 2017 19:38:10 UTC+8, Patrik Nordwall wrote:
>
>
>
> On Fri, Jan 6, 2017 at 2:57 AM, Dai Yinhua <yhdai...@gmail.com
> > wrote:
>
>> Hi Patrik,
>>
>> From Akka documentation, "Note that *Cluster Sharding*
>> <http://doc.akka.io/docs/ak
nal config in order to function,
>> so I like this approach, but I could easily argue the other side. I was
>> mostly just making the point that Kryo is a valid option, not that it's
>> necessarily a better one...
>>
>> On Sat, Mar 18, 2017 at 2:02 AM, Dai Yinhua <y
>
> Hi Justin,
>
Thank you for your information and suggestion.
I have read your blog but I can't see the benefit of using scala to
describe the schema over using an external description file(like .proto).
But I look forward your unfinished part.
--
>> Read the docs:
ing to all
> of these nodes, you wind up with an inconsistent state, and can easily fall
> into data corruption...
>
> On Sat, Mar 18, 2017 at 5:05 AM, Dai Yinhua <yhdai...@gmail.com
> > wrote:
>
>> @Patrik, I have read the akka document about split brain resolver, but
>&g
essarily a better one...
>
> On Sat, Mar 18, 2017 at 2:02 AM, Dai Yinhua <yhdai...@gmail.com
> > wrote:
>
>> Hi Justin,
>>>
>>
>> Thank you for your information and suggestion.
>> I have read your blog but I can't see the benefit of using scala to
&g
>
> @Patrik, I have read the akka document about split brain resolver, but
> could you please explain a little bit more to help me understand why does
> it happen?
>
If node A is experiencing long GC, and then node A is firstly marked as
unreachable and then marked as down and later removed
Anybody knows how to run akka multi node testing in java?
Is there any example code?
--
>> Read the docs: http://akka.io/docs/
>> Check the FAQ:
>> http://doc.akka.io/docs/akka/current/additional/faq.html
>> Search the archives:
Sending ShardRegion.GetClusterShardingStats to a local shard region can get
all shard regions, and their shards and underlying entities.
On Wednesday, 22 March 2017 10:53:27 UTC+8, Leo Wolf wrote:
>
> Hi there,
>
> I have constructed the shard region in actor system, but I wonder if
> there's
Does it happen if all servers are inside a LAN?
--
>> Read the docs: http://akka.io/docs/
>> Check the FAQ:
>> http://doc.akka.io/docs/akka/current/additional/faq.html
>> Search the archives: https://groups.google.com/group/akka-user
---
You
Hi team,
I am aware that akka cluster may be partitioned to 2 clusters with
auto-downing.
But I can't understand how does it happen?
If node A is performing a long GC? And then node A become unreachable,
after a while, node A is marked as down, why the cluster is partitioned in
this case?
Can
>
> In general these dead letters are typically not much to worry about, but I
> agree it'd be neat to find out where they're coming from.
>
>
> Arnout
>
> On Fri, Apr 14, 2017 at 3:56 AM, Dai Yinhua <yhdai...@gmail.com
> > wrote:
>
>> I have the same issu
I have the same issue with
http://stackoverflow.com/questions/29589909/akka-cluster-memberup-message-from-dead-letters-not-delivered
But I don't see any reasonable explanation in the above post, can you help
me identify the root cause?
Thank you.
--
>> Read the docs:
Konrad,
Really? I was thing serialization would be needed for inter process
communication.
--
>> Read the docs: http://akka.io/docs/
>> Check the FAQ:
>> http://doc.akka.io/docs/akka/current/additional/faq.html
>> Search the archives:
Thank you guys.
I would try to find out the reproduce procedure, and reported to github.
On Saturday, 4 March 2017 00:09:21 UTC+8, Justin du coeur wrote:
>
> On Thu, Mar 2, 2017 at 8:55 PM, Dai Yinhua <yhdai...@gmail.com
> > wrote:
>
>> I am using AKKA 2.4.12 and kryo
A few updates.
1. The crash only happened when I run akka cluster in different nodes, i.e.
cross node transportation.
If I start akka cluster in one single server, it won't crash.
2. When I set post-serialization-transformations to "off"(previous is
"lz4,aes"), the crash is gone even run
actually failing.
>>
>> --
>> Konrad `ktoso` Malawski
>> Akka <http://akka.io> @ Lightbend <http://lightbend.com>
>>
>> On 2 March 2017 at 11:57:41, Dai Yinhua (yhdai...@gmail.com )
>> wrote:
>>
>> Hi team,
>>
>> I encounter
OK, thanks.
On Tuesday, 25 April 2017 16:59:10 UTC+8, Akka Team wrote:
>
> Hi Dai,
>
> I'm afraid it is currently only possible to run the multi-node tests with
> Scala + SBT
>
> --
> Johan
> Akka Team
>
> On Wed, Mar 22, 2017 at 3:11 AM, Dai Yinhua <yhdai..
Hi Akka team,
In http://doc.akka.io/docs/akka/current/java/dispatchers.html, it said
The default dispatcher gives excellent performance in most cases
I just want to know in what case the default dispatcher is not performing
good, and when we write customized dispatcher, which kind of
I don't know, I'm reading through Akka document, so just wondering why Akka
provides customized dispatcher and in what case should write customized
dispatchers.
--
>> Read the docs: http://akka.io/docs/
>> Check the FAQ:
>>
Understood, thank you.
--
>> Read the docs: http://akka.io/docs/
>> Check the FAQ:
>> http://doc.akka.io/docs/akka/current/additional/faq.html
>> Search the archives: https://groups.google.com/group/akka-user
---
You received this message because
Hi team,
I am using akka cluster sharding for an analytics application in
production. And we are using kubernetes to run all akka jvms in container.
The thing I feel awkward is that how to collect all logs from all
containers.
I know a popular solution for distributed application log is ELK,
rg - it works very similar to
> how ELK does, but as for me - easier to setup.
>
> Also, you can try some of hosted solutions,
>
> - https://sentry.io/welcome/
> - logz.io
>
>
> середа, 17 травня 2017 р. 10:28:44 UTC+3 користувач Dai Yinhua написав:
>>
I'm using akka cluster sharding to build for *a long connection streaming
*distributed
calculation engine.
It's driven by request, basically for each request, there will be one
entity actor started for calculation of that request, and this is a
streaming request, which means the calculation
I am using *akka cluster sharding *to build a long running calculation
service, and I have set auto-down to false.
And we have mechanism that *when one jvm get crashed it will be restarted
immediately* by some external monitoring tools.
I would like to confirm below behaviors when some jvm get
ly...
>
> On Fri, May 26, 2017 at 4:52 AM, Dai Yinhua <yhdai...@gmail.com
> > wrote:
>
>> I am using *akka cluster sharding *to build a long running calculation
>> service, and I have set auto-down to false.
>> And we have mechanism that *when one jvm get cr
Patrik,
Specifically, we are using kubernetes and container based akka cluster,
where kubernetes will automatically restart any container that crashed.
I haven't got idea how to add "Down" logic before kubernetes restarts the
crashed container.
--
>> Read the docs:
How can I enable the akka cluster http management?
Should I call ClusterHttpManagement(cluster1).start() to enable it?
And does it supported by a singleton actor internally so that I can call it
on every node of akka cluster instance?
Also how should I set akka.cluster.http.management.hostname
55 matches
Mail list logo
