connect).
-Endre
On Mon, Jul 21, 2014 at 7:46 AM, shikhar shik...@schmizz.net wrote:
Also I think the first of those log lines should be at the DEBUG level,
since shortly after this INFO logging happens:
[Cluster(akka://mycluster)] Cluster Node [akka.tcp://mycluster@myhose:8402]
- Leader
After the cluster has been up for a longish period ( a day or so), and
only then, I'm seeing:
[2014-07-20 00:00:00,708][ERROR][akka.remote.EndpointWriter]
[akka.tcp://x...@.com:/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2F%40%3A-16/endpointWriter]
Transient
Thanks for the input Patrik.
I've confirmed that the issue wasn't anything in the application by
isolating it in a simple project
https://github.com/shikhar/akka-cluster-churn, see Churn.scala
https://github.com/shikhar/akka-cluster-churn/blob/master/src/main/scala/Churn.scala.
I set the payload
When a node initiates a leave for itself, the exit is pretty verbose.
i.e. these are logged on every cluster member
[2014-07-21 05:36:23,181][INFO ][akka.dummy ]
[Cluster(akka://mycluster)] Cluster Node [akka.tcp://mycluster@myhost:8402]
- Marking exiting node(s) as UNREACHABLE
AM, shikhar shik...@schmizz.net wrote:
When a node initiates a leave for itself, the exit is pretty verbose.
i.e. these are logged on every cluster member
[2014-07-21 05:36:23,181][INFO ][akka.dummy ]
[Cluster(akka://mycluster)] Cluster Node [akka.tcp://mycluster@myhost:8402
I am seeing the sending HandOverToMe to [None] tries at startup as well.
If I change this conditional
https://github.com/akka/akka/blob/release-2.3/akka-contrib/src/main/scala/akka/contrib/pattern/ClusterSingletonManager.scala#L498
to instead read
if (count = maxHandOverRetries
Thanks for the thoughtful reply Ronald!
On Tue, May 6, 2014 at 11:58 PM, Akka Team akka.offic...@gmail.com wrote:
Hi Shikhar,
thanks for sharing!
There are many possible ways of dealing with partitions in a distributed
system, and it depends very much on the use-case what the best
I have been hacking on a discovery plugin for
elasticsearchhttps://github.com/shikhar/eskka using
akka cluster and I wanted to add some automated downing, and the
auto-down-unreachable-after is not really an option since it can lead to
split brain.
So I went with the approach of using
