[akka-user] akka-cluster split brain when enable auto-down and set a node random package loss rate 50%

In a 5-node cluster, hypothesis the nodes is A,B,C,D,E. All nodes monitor each other, enable auto-down, and we set the node-A random package loss rate 50%, after a period of time, the cluster will divide into two or more clusters. How can I fix this problem? -- >> Read the

Re: [akka-user] akka http client only excecute the `max-connections` times ~

thanks for your reply ~ i changed my code like this , it works well when i set the `max-connections = 10` ``` (1 to 500).foreach{idx=> val futureResponse = Source.single(httpRequest->1).via(poolFlow).runWith(Sink.head).map(_._1).flatMap(Future.fromTry) futureResponse.andThen{ case

[akka-user] Akka auto-down and akka-cluster split brain

In a 5-node cluster, hypothesis the nodes is A,B,C,D,E. All nodes monitor each other, enable auto-down, and we set the node-A random package loss rate 50%, after a period of time, all nodes in the cluster will restart. The result we expect is one or two nodes restart, how can I fix this

Re: [akka-user] Re: Akka Cluster + Leveldb : Persistence failure when replaying events for ...

Hi Patrik, Thank you very much for your reply. Correct me if I'm wrong. By "single point of failure" what I meant was, in case of any failure in the primary node, the events which is not yet persisted in the leveldb will be lost. But the events which is already persisted should be available

Re: [akka-user] Configurable parallelism/elastic groupBy

Or perhaps you are talking about something like http://doc.akka.io/docs/akka/2.4.8/scala/stream/stream-cookbook.html#Balancing_jobs_to_a_fixed_pool_of_workers but using the Partition stage instead of Balance

[akka-user] Pass Future to Sink.ignore, how do I know it's completed

My Sink receives a Future. I don't want to do anything with it so I use Sink.ignore but then I don't know when it's completed and that I need to know. Should I write a custom Sink or does the API already have a solution for this? Gary -- >> Read the docs: http://akka.io/docs/

Re: [akka-user] Re: Make HTTPS request using akka-http to jenkins server

The jenkins server has a self signed certificate which is not trusted by akka-http. I downloaded the certificate and placed it in the project directory. Following is the certificate config ssl-config.ssl { trustManager = { stores = [ { type = "PEM", path = "globalsign.crt" } ]

[akka-user] Retry only has meaning for restart in SuperVisorStragety?

Hello, From the doc and my testing, looks like "retry only is meaningful if I want to restart the Actor? For resume() it will not apply the retry? Do I understand it correctly? Thanks, Yan -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >>

[akka-user] Re: Akka Java IO TLS

After rethinking and researching was wondering if I can configure/code the netty API which Akka uses to achieve the TLS. I am now sure how efficient is this. Any help would be greatly appreciated Thanks Vinay On Monday, July 18, 2016 at 11:13:33 AM UTC-5, Vinay Gajjala wrote: > > Hi > > I am

Re: [akka-user] Question about fork-join with actors

There are a lot of ways you *could* slice this, but the most straightforward is the simple Actor-per-request model. Actors are fairly lightweight, so it's sometimes worthwhile to just stand one up for a complex request like this. So you instantiate an Actor in charge of managing the

Re: [akka-user] Re: Akka Cluster + Leveldb : Persistence failure when replaying events for ...

Just an observation: this is a common enough point of confusion that I actually think y'all might want to consider removing the LevelDB default. As I recently discovered, it's almost ridiculously easy to boot up a local Cassandra development "cluster" using ccm .

Re: [akka-user] Configurable parallelism/elastic groupBy

Thanks. That gives me some terms to Google, but any further pointers welcome. I see references to FlexiRoute being replaced by GraphStage. Presumably that's what I need to study next? On Thu, Jul 21, 2016 at 12:59 AM, Viktor Klang wrote: > A routing stage with consistent

[akka-user] What is ProtocolStateActor.invoke and why is it so time consuming?

We have been doing load tests on our development environment to isolate out slow operations in our system. One of the endpoints that NewRelic reported taking lots of time is ProtocolStateActor.invoke. The output is provided in the attached, redacted for NDA reasons, screenshot. Can anyone tell

Re: [akka-user] Error about download akka proj from github and open it as a proj in intellij

By the way, the error shows this message: Very thanks for

Re: [akka-user] Error about download akka proj from github and open it as a proj in intellij

Hi Konrad, Thank you for getting back to me. I have create a scala test file under Akka-http-sprayjson and the path is "/akka/akka-http-marshallers-scala/akka-http-spray-json/src/main/scala/akka/http/scaladsl/marshallers/sprayjson/UploadHandler.scala", and package it as package

Re: [akka-user] Re: akka-http web socket issue

Yes it works. What's wrong about Streamed? That's a feature that it's streaming the data – consume it using the dataBytes contained in the Streamed message. -- Konrad `ktoso` Malawski Akka @ Lightbend On 21 July 2016 at 10:45:03, allobi...@gmail.com

[akka-user] Re: akka-http web socket issue

does this work when receiving large json data..? i have problem receiving large json data because sometimes it returns TextMessage.Streamed instead of TextMessage.Strict and another issue is when connecting to wss://s2.ripple.com:443 i can't connect using this url but can connect to other

[akka-user] Re: akka-http web socket issue

does this work when receiving large json data ? On Thursday, July 7, 2016 at 6:34:02 AM UTC+8, Eric Swenson wrote: > > I wrote a simple python client: > > $ cat ws-test.py > import os > from websocket import create_connection > > eiid=os.getenv("EIID") > token=os.getenv("BEARER_TOKEN") >

Re: [akka-user] Error about download akka proj from github and open it as a proj in intellij

Hi Leo, what PR are you working on? But I found out there are lots of errors in build.sbt in every directory. For instance, For the most part you can ignore these if intellij doesn't pick them up. The import into intellij from sbt feature works properly. And, I create a test.scala in

[akka-user] Error about download akka proj from github and open it as a proj in intellij

Hi, I'm new to akka-proj. I encounter some problems about modify the akka-proj, and found you have made some pull request on it so I decide to ask you about it. I have forked the akka-proj, download it, and open it as a project in intellij. But I found out there are lots of errors in build.sbt

Re: [akka-user] akka http client only excecute the `max-connections` times ~

You're not using the data you've requested, thus stalling the connections. This is by design. Akka HTTP is a *streaming* HTTP Client. Please read the docs about this: http://doc.akka.io/docs/akka/2.4/scala/http/implications-of-streaming-http-entity.html -- Konrad `ktoso` Malawski Akka

[akka-user] A problem ablout Akka cluster brain crack

Description of the problem: In a 3-node cluster, all nodes monitor each other, when a connection between two nodes fails, the cluster divide into 3 cluster, every cluster have one node. Example: For example, In 3-node cluster, the default value of monitored-by-nr-of-members is 5, and

[akka-user] Is Akka the right choice for my simple distributed system?

I wonder if the community can help me get started. I’m trying to design the architecture of a project and I think that using Akka may make sense, but I am completely new to distributed systems and to Akka (I am a very experienced developer, but my expertise is image processing on Windows!).

Re: [akka-user] Configurable parallelism/elastic groupBy

A routing stage with consistent hashing and then a N-Way merge to insert into db? -- Cheers, √ On Jul 20, 2016 9:09 PM, "Richard Rodseth" wrote: > I'm sure I've asked this before in numerous ways, but it's still an issue > for me. > > I have an ETL stream that reads

[akka-user] Question about fork-join with actors

I have a classic question: how to fork some work and then join the results. Let me explain the problem: There is a security manager that asks several security providers (e.g. Active Directory, Tivoli, Mainframe) if a given call is authorized. If all the security providers say "yes", the call

Re: [akka-user] Re: Akka Cluster + Leveldb : Persistence failure when replaying events for ...

SharedLeveldbJournal is not resillient. It's a single point of failure since it is only running on one node. It's only intended for demo examples. Please use a real distributed jounal, such as akka-persistence-cassandra /Patrik tors 21 juli 2016 kl. 01:24 skrev Manoj Santhakumaran