How to run Beam in cluster

https://github.com/LBNL-UCB-STI/beam/tree/rw/router-perf-artavazd-do-not-batch-updated-matsim

Тут бранча где я паралели его с помощью Akka Cluster.
1) Надо положить пропатченный matsim(там куча классов помечена как Serializable чтобы без особого секса уметь их сериализовать в акка): https://drive.google.com/open?id=1Z0G7phbJHA5PSrptH_PRd9eT2gAbWGdH в кеш мавен, у меня он тут: ~/.m2/repository/org/matsim/matsim/0.10.0-SNAPSHOT/
2) Переключится в бранчу rw/router-perf-artavazd-do-not-batch-updated-matsim
3) Запустить seed ноду, которая также является и рабочей чере
./gradlew -PmainClass=beam.sim.RunBeamCluster -PappArgs="['--config', 'test/input/beamville/beam.conf', '--node-host', '127.0.0.1', '--node-port', '2551', '--seed-address', '127.0.0.1:2551']" execute --offline
Подождать пока нода поднялась - появится сообщение типа:
23:53:45.646 [ClusterSystem-akka.actor.default-dispatcher-2] INFO  beam.router.r5.NetworkCoordinator - Initializing router by reading network from: /Users/abalaian/Downloads/beam/test/input/beamville/r5/network.dat
23:53:46.472 [ClusterSystem-akka.actor.default-dispatcher-2] INFO  beam.router.osm.TollCalculator - Ways keys size: 8
23:53:46.532 [ClusterSystem-akka.actor.default-dispatcher-9] INFO  beam.router.r5.R5RoutingWorker_v2 - R5RoutingWorker_v2[1517957028] `akka://ClusterSystem/user/statsService/singleton/workerRouter/c1` is ready
23:53:46.533 [ClusterSystem-akka.actor.default-dispatcher-9] INFO  beam.router.r5.R5RoutingWorker_v2 - Num of avaiable processors: 4. Will use: 2


4) Запустить мастер ноду, которая и занимается расчетом
./gradlew run -PappArgs="['--config', 'test/input/beamville/beam.conf', '--node-host', '127.0.0.1', '--node-port', '2552', '--seed-address', '127.0.0.1:2551']"
Надо подождать немного инициализацию и начнется симуляция. Увидишь сообщения
` TransitInited[546b4264-edf5-4bde-8bef-9d01e8532346] in 4633 ms. transitSchedule[1905278197] keys: 44
23:56:36.805 [ClusterSystem-akka.actor.default-dispatcher-11] INFO  beam.agentsim.agents.Population - Initialized 21 households
23:56:36.823 [ClusterSystem-akka.actor.default-dispatcher-2] INFO  beam.sim.BeamMobsim$$anon$1 - Initialized 50 people
23:56:36.823 [ClusterSystem-akka.actor.default-dispatcher-2] INFO  beam.sim.BeamMobsim$$anon$1 - Initialized 22 personal vehicles
23:56:36.824 [ClusterSystem-akka.actor.default-dispatcher-2] INFO  beam.sim.BeamMobsim$$anon$1 - Initialized 25 ride hailing agents
23:56:37.208 [ClusterSystem-akka.actor.default-dispatcher-8] INFO  beam.sim.InitTransitions - Finished Transit initialization trips, 44. Executed in 377 ms
23:56:37.211 [ClusterSystem-akka.actor.default-dispatcher-13] INFO  beam.sim.BeamMobsim$$anon$1 - Initialized transitions
23:56:37.254 [ClusterSystem-akka.actor.default-dispatcher-16] INFO  beam.router.BeamRouter - Sending InitTransit_v2  Actor[akka://ClusterSystem@127.0.0.1:2551/user/statsServiceProxy#34589340
23:56:40.691 [ClusterSystem-akka.actor.default-dispatcher-14] INFO  beam.sim.BeamMobsim$$anon$1 - Transit schedule has been initialized
23:56:40.692 [ClusterSystem-akka.actor.default-dispatcher-14] INFO  beam.sim.BeamMobsim$$anon$1 - rideHailManagerTimerScheduled
23:56:40.706 [ClusterSystem-akka.actor.default-dispatcher-11] INFO  beam.sim.BeamMobsim$$anon$1 - Running BEAM Mobsim
23:56:40.708 [ClusterSystem-akka.actor.default-dispatcher-14] INFO  beam.agentsim.scheduler.BeamAgentScheduler - starting scheduler at iteration 0
23:56:40.792 [ClusterSystem-akka.actor.default-dispatcher-8] INFO  beam.agentsim.scheduler.BeamAgentScheduler - Hour 0.5 completed. 0.2(GB)
23:56:40.800 [ClusterSystem-akka.actor.default-dispatcher-13] INFO  beam.agentsim.scheduler.BeamAgentScheduler - Hour 1.0 completed. 0.2(GB)
23:56:40.806 [ClusterSystem-akka.actor.default-dispatcher-13] INFO  beam.agentsim.scheduler.BeamAgentScheduler - Hour 1.5 completed. 0.2(GB)
23:56:40.809 [ClusterSystem-akka.actor.default-dispatcher-3] INFO  beam.agentsim.scheduler.BeamAgentScheduler - Hour 2.0 completed. 0.2(GB)
23:56:40.815 [ClusterSystem-akka.actor.default-dispatcher-15] INFO  beam.agentsim.scheduler.BeamAgentScheduler - Hour 2.5 completed. 0.2(GB)
23:56:40.819 [ClusterSystem-akka.actor.default-dispatcher-11] INFO  beam.agentsim.scheduler.BeamAgentScheduler - Hour 3.0 completed. 0.2(GB)
23:56:40.824 [ClusterSystem-akka.actor.default-dispatcher-13] INFO  beam.agentsim.scheduler.BeamAgentScheduler - Hour 3.5 completed. 0.2(GB)