vyshane / klusterd Goto Github PK
View Code? Open in Web Editor NEWAkka Clustering with Kubernetes: A Sample Project
Akka Clustering with Kubernetes: A Sample Project
Hey, I've test that if I initially start 4 replica, than there is high risk to trigger brain splitting(because there is no "first seed node" to avoid brain split). Though we can start the klustrd as 1 replica,than scale out, but this might also happen if the rc restart.
The log,when I initially start 4 replica:
root@SZV1000050172:/home/docker/workspace/xuanhaoran/klusterd-master/deployment# kubectl get pods |grep klusterd
klusterd-42t9x 1/1 Running 0 4m
klusterd-gh8iy 1/1 Running 0 4m
klusterd-h7h2v 1/1 Running 0 4m
klusterd-zsi8h 1/1 Running 0 4m
root@SZV1000050172:/home/docker/workspace/xuanhaoran/klusterd-master/deployment# kubectl logs -f klusterd-42t9x
[DEBUG] [03/20/2017 08:59:57.965] [main] [EventStream] StandardOutLogger started
INFO - Slf4jLogger started
[DEBUG] [03/20/2017 08:59:58.592] [main] [EventStream(akka://klusterd)] logger log1-Slf4jLogger started
[DEBUG] [03/20/2017 08:59:58.594] [main] [EventStream(akka://klusterd)] Default Loggers started
INFO 08:59:58.696UTC akka.remote.Remoting - Starting remoting
INFO 08:59:58.918UTC akka.remote.Remoting - Remoting started; listening on addresses :[akka.tcp://[email protected]:2551]
INFO 08:59:58.939UTC akka.cluster.Cluster(akka://klusterd) - Cluster Node [akka.tcp://[email protected]:2551] - Starting up...
INFO 08:59:59.097UTC akka.cluster.Cluster(akka://klusterd) - Cluster Node [akka.tcp://[email protected]:2551] - Registered cluster JMX MBean [akka:type=Cluster]
INFO 08:59:59.097UTC akka.cluster.Cluster(akka://klusterd) - Cluster Node [akka.tcp://[email protected]:2551] - Started up successfully
INFO 08:59:59.133UTC akka.cluster.Cluster(akka://klusterd) - Cluster Node [akka.tcp://[email protected]:2551] - Metrics will be retreived from MBeans, and may be incorrect on some platforms. To increase metric accuracy add the 'sigar.jar' to the classpath and the appropriate platform-specific native libary to 'java.library.path'. Reason: java.lang.ClassNotFoundException: org.hyperic.sigar.Sigar
INFO 08:59:59.170UTC akka.cluster.Cluster(akka://klusterd) - Cluster Node [akka.tcp://[email protected]:2551] - Metrics collection has started successfully
INFO 08:59:59.190UTC akka.actor.ActorSystemImpl(klusterd) - Configured seed nodes: akka.tcp://[email protected]:2551, akka.tcp://[email protected]:2551
INFO 08:59:59.794UTC akka.cluster.Cluster(akka://klusterd) - Cluster Node [akka.tcp://[email protected]:2551] - Welcome from [akka.tcp://[email protected]:2551]
INFO 08:59:59.814UTC akka.tcp://[email protected]:2551/user/cluster-monitor - Cluster member up: akka.tcp://[email protected]:2551
INFO 09:00:00.184UTC akka.tcp://[email protected]:2551/user/cluster-monitor - Cluster member up: akka.tcp://[email protected]:2551
root@SZV1000050172:/home/docker/workspace/xuanhaoran/klusterd-master/deployment# kubectl logs -f klusterd-gh8iy
[DEBUG] [03/20/2017 09:01:00.898] [main] [EventStream] StandardOutLogger started
INFO - Slf4jLogger started
[DEBUG] [03/20/2017 09:01:01.302] [main] [EventStream(akka://klusterd)] logger log1-Slf4jLogger started
[DEBUG] [03/20/2017 09:01:01.303] [main] [EventStream(akka://klusterd)] Default Loggers started
INFO 09:01:01.360UTC akka.remote.Remoting - Starting remoting
INFO 09:01:01.582UTC akka.remote.Remoting - Remoting started; listening on addresses :[akka.tcp://[email protected]:2551]
INFO 09:01:01.596UTC akka.cluster.Cluster(akka://klusterd) - Cluster Node [akka.tcp://[email protected]:2551] - Starting up...
INFO 09:01:01.735UTC akka.cluster.Cluster(akka://klusterd) - Cluster Node [akka.tcp://[email protected]:2551] - Registered cluster JMX MBean [akka:type=Cluster]
INFO 09:01:01.735UTC akka.cluster.Cluster(akka://klusterd) - Cluster Node [akka.tcp://[email protected]:2551] - Started up successfully
INFO 09:01:01.744UTC akka.cluster.Cluster(akka://klusterd) - Cluster Node [akka.tcp://[email protected]:2551] - Metrics will be retreived from MBeans, and may be incorrect on some platforms. To increase metric accuracy add the 'sigar.jar' to the classpath and the appropriate platform-specific native libary to 'java.library.path'. Reason: java.lang.ClassNotFoundException: org.hyperic.sigar.Sigar
INFO 09:01:01.745UTC akka.cluster.Cluster(akka://klusterd) - Cluster Node [akka.tcp://[email protected]:2551] - Metrics collection has started successfully
INFO 09:01:01.772UTC akka.actor.ActorSystemImpl(klusterd) - Configured seed nodes: akka.tcp://[email protected]:2551, akka.tcp://[email protected]:2551
WARN 09:01:02.044UTC akka.tcp://[email protected]:2551/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fklusterd%40172.16.37.3%3A2551-0 - Association with remote system [akka.tcp://[email protected]:2551] has failed, address is now gated for [5000] ms. Reason: [Association failed with [akka.tcp://[email protected]:2551]] Caused by: [Connection refused: /172.16.37.3:2551]
WARN 09:01:02.046UTC akka.tcp://[email protected]:2551/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fklusterd%40172.16.90.2%3A2551-1 - Association with remote system [akka.tcp://[email protected]:2551] has failed, address is now gated for [5000] ms. Reason: [Association failed with [akka.tcp://[email protected]:2551]] Caused by: [Connection refused: /172.16.90.2:2551]
INFO 09:01:12.349UTC akka.cluster.Cluster(akka://klusterd) - Cluster Node [akka.tcp://[email protected]:2551] - Welcome from [akka.tcp://[email protected]:2551]
INFO 09:01:12.381UTC akka.tcp://[email protected]:2551/user/cluster-monitor - Cluster member up: akka.tcp://[email protected]:2551
INFO 09:01:12.665UTC akka.tcp://[email protected]:2551/user/cluster-monitor - Cluster member up: akka.tcp://[email protected]:2551
as you can see ,actually there are two akka cluster created:
akka.tcp://[email protected]:2551 + akka.tcp://[email protected]:2551(seed)
akka.tcp://[email protected]:2551 + akka.tcp://[email protected]:2551(seed)
A declarative, efficient, and flexible JavaScript library for building user interfaces.
๐ Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
An Open Source Machine Learning Framework for Everyone
The Web framework for perfectionists with deadlines.
A PHP framework for web artisans
Bring data to life with SVG, Canvas and HTML. ๐๐๐
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
Some thing interesting about web. New door for the world.
A server is a program made to process requests and deliver data to clients.
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
Some thing interesting about visualization, use data art
Some thing interesting about game, make everyone happy.
We are working to build community through open source technology. NB: members must have two-factor auth.
Open source projects and samples from Microsoft.
Google โค๏ธ Open Source for everyone.
Alibaba Open Source for everyone
Data-Driven Documents codes.
China tencent open source team.