To me it looks like your persistent actor fails to start because Cassandra
is not responding.
Maybe you can try again with LevelDB? Or check that Cassandra is actually
running on localhost:7104?
Best regards,
Anders Båtstrand
torsdag 28. mai 2015 00.03.21 UTC+2 skrev Clay McCoy følgende:
>
> I have a single Akka node running local to my machine. It seems to join
> itself fine. Messages never make it to the sharded actors and I can't tell
> if they are created. Code and logs below, thanks in advance.
>
> application.conf:
>
> akka {
> actor {
> provider = "akka.cluster.ClusterActorRefProvider"
> }
> remote {
> log-remote-lifecycle-events = off
> netty.tcp {
> hostname = "127.0.0.1"
> port = 2551
> }
> }
> cluster {
> seed-nodes = ["akka.tcp://[email protected]:2551"]
> auto-down-unreachable-after = 10s
> }
> }
>
>
> * actor sending to sharded actor:
>
> class ClusterTestWrapperActor(val clusterSharding: ClusterSharding) extends
> Actor with ActorLogging {
> implicit val timeout = Timeout(1 second)
>
> override def receive: Receive = {
> case msg: NewMessage =>
> val clusterTestActor: ActorRef =
> clusterSharding.shardRegion("ClusterTest")
> clusterTestActor ! msg
> case msg: GetMessages =>
> val clusterTestActor: ActorRef =
> clusterSharding.shardRegion("ClusterTest")
> val future = clusterTestActor ? msg
> val result = Await.result(future, timeout.duration)
> sender() ! result
> }
> }
>
>
> * sharded actor (this is the one who never gets the messages):
>
> class ClusterTestActor() extends PersistentActor with ActorLogging {
> var messages: List[String] = Nil
>
> var name: String = _ // I'd rather have this be a val set in the
> constructor, but I don't know how since the shard constructs it
> override def persistenceId: String = s"ClusterTestActor-$name" // not sure
> the relationship between this and akka cluster id
>
> override def receiveCommand: Receive = {
> case msg: NewMessage =>
> println(s"*** ClusterTestActor receive $msg")
> name = msg.name
> persist(msg) { event =>
> messages = s"${event.message}" :: messages
> }
> case msg: GetMessages =>
> println(s"*** ClusterTestActor receive $msg")
> sender() ! Messages(msg.name, messages)
> }
>
> override def receiveRecover: Receive = {
> case msg: NewMessage =>
> messages = s"**recovered** ${msg.message}" :: messages
> println(s"** recover $msg")
> }
> }
> sealed trait Inputs
> case class GetMessages(name: String) extends Inputs
> case class NewMessage(name: String, message: String) extends Inputs
> sealed trait Outputs
> case class Messages(name: String, messages: List[String]) extends Outputs
>
>
> * cluster sharding start (I can verify that this is starting, and that the
> IdExtractor is only used to see if it is defined for the partial function,
> never actually evaluated/extracted):
>
>
> val idExtractor: ShardRegion.IdExtractor = {
> case msg @ GetMessages(name) =>
> println(s"******** ***${name}**")
> (name, msg)
> case msg @ NewMessage(name, message) =>
> println(s"********${name}**")
> (name, msg)
> }
>
> val shardResolver: ShardRegion.ShardResolver = {
> case GetMessages(name) =>
> name.head.toString
> case NewMessage(name, _) =>
> println(s"**${name.head.toString}**")
> name.head.toString
> }
>
> clusterSharding.start(
> typeName = "ClusterTest",
> entryProps = Some(Props[ClusterTestActor]),
> idExtractor = idExtractor,
> shardResolver = shardResolver)
>
> I've also got a BroadcastActor for monitoring and it strangely receives the
> Messages that I send, but only the first one.
>
> class BroadcastActor extends Actor with ActorLogging {
> private val cluster = Cluster(context.system)
>
> override def preStart(): Unit = {
> cluster.subscribe(
> self,
> initialStateMode = InitialStateAsEvents,
> classOf[MemberEvent],
> classOf[UnreachableMember])
> }
> override def postStop(): Unit = cluster.unsubscribe(self)
>
> def receive = {
> case msg =>
> log.info(s"$msg")
> }
> }
>
>
> * relevant logs make up the rest of this post:
>
>
> Akka config:
> Config(SimpleConfigObject({"PID":"35270","akka":{"actor":{"creation-timeout":"20s","debug":{"autoreceive":"off","event-stream":"off","fsm":"off","lifecycle":"off","receive":"off","router-misconfiguration":"off","unhandled":"off"},"default-dispatcher":{"attempt-teamwork":"on","default-executor":{"fallback":"fork-join-executor"},"executor":"default-executor","fork-join-executor":{"parallelism-factor":3,"parallelism-max":64,"parallelism-min":8},"mailbox-requirement":"","shutdown-timeout":"1s","thread-pool-executor":{"allow-core-timeout":"on","core-pool-size-factor":3,"core-pool-size-max":64,"core-pool-size-min":8,"keep-alive-time":"60s","max-pool-size-factor":3,"max-pool-size-max":64,"max-pool-size-min":8,"task-queue-size":-1,"task-queue-type":"linked"},"throughput":5,"throughput-deadline-time":"0ms","type":"Dispatcher"},"default-mailbox":{"mailbox-capacity":1000,"mailbox-push-timeout-time":"10s","mailbox-type":"akka.dispatch.UnboundedMailbox","stash-capacity":-1},"deployment":{"default":{"cluster":{"allow-local-routees":"on","enabled":"off","max-nr-of-instances-per-node":1,"routees-path":"","use-role":""},"dispatcher":"","mailbox":"","metrics-selector":"mix","nr-of-instances":1,"remote":"","resizer":{"backoff-rate":0.1,"backoff-threshold":0.3,"enabled":"off","lower-bound":1,"messages-per-resize":10,"pressure-threshold":1,"rampup-rate":0.2,"upper-bound":10},"routees":{"paths":[]},"router":"from-code","tail-chopping-router":{"interval":"10
> milliseconds"},"target":{"nodes":[]},"virtual-nodes-factor":10,"within":"5
> seconds"}},"dsl":{"default-timeout":"5s","inbox-size":1000},"guardian-supervisor-strategy":"akka.actor.DefaultSupervisorStrategy","mailbox":{"bounded-deque-based":{"mailbox-type":"akka.dispatch.BoundedDequeBasedMailbox"},"bounded-queue-based":{"mailbox-type":"akka.dispatch.BoundedMailbox"},"requirements":{"akka.dispatch.BoundedDequeBasedMessageQueueSemantics":"akka.actor.mailbox.bounded-deque-based","akka.dispatch.BoundedMessageQueueSemantics":"akka.actor.mailbox.bounded-queue-based","akka.dispatch.DequeBasedMessageQueueSemantics":"akka.actor.mailbox.unbounded-deque-based","akka.dispatch.MultipleConsumerSemantics":"akka.actor.mailbox.unbounded-queue-based","akka.dispatch.UnboundedDequeBasedMessageQueueSemantics":"akka.actor.mailbox.unbounded-deque-based","akka.dispatch.UnboundedMessageQueueSemantics":"akka.actor.mailbox.unbounded-queue-based"},"unbounded-deque-based":{"mailbox-type":"akka.dispatch.UnboundedDequeBasedMailbox"},"unbounded-queue-based":{"mailbox-type":"akka.dispatch.UnboundedMailbox"}},"provider":"akka.cluster.ClusterActorRefProvider","reaper-interval":"5s","router":{"type-mapping":{"adaptive-group":"akka.cluster.routing.AdaptiveLoadBalancingGroup","adaptive-pool":"akka.cluster.routing.AdaptiveLoadBalancingPool","balancing-pool":"akka.routing.BalancingPool","broadcast-group":"akka.routing.BroadcastGroup","broadcast-pool":"akka.routing.BroadcastPool","consistent-hashing-group":"akka.routing.ConsistentHashingGroup","consistent-hashing-pool":"akka.routing.ConsistentHashingPool","from-code":"akka.routing.NoRouter","random-group":"akka.routing.RandomGroup","random-pool":"akka.routing.RandomPool","round-robin-group":"akka.routing.RoundRobinGroup","round-robin-pool":"akka.routing.RoundRobinPool","scatter-gather-group":"akka.routing.ScatterGatherFirstCompletedGroup","scatter-gather-pool":"akka.routing.ScatterGatherFirstCompletedPool","smallest-mailbox-pool":"akka.routing.SmallestMailboxPool","tail-chopping-group":"akka.routing.TailChoppingGroup","tail-chopping-pool":"akka.routing.TailChoppingPool"}},"serialization-bindings":{"[B":"bytes","akka.actor.ActorSelectionMessage":"akka-containers","akka.cluster.ClusterMessage":"akka-cluster","akka.contrib.pattern.DistributedPubSubMessage":"akka-pubsub","akka.persistence.serialization.Message":"akka-persistence-message","akka.persistence.serialization.Snapshot":"akka-persistence-snapshot","akka.remote.DaemonMsgCreate":"daemon-create","com.google.protobuf.GeneratedMessage":"proto","java.io.Serializable":"java"},"serialize-creators":"off","serialize-messages":"off","serializers":{"akka-cluster":"akka.cluster.protobuf.ClusterMessageSerializer","akka-containers":"akka.remote.serialization.MessageContainerSerializer","akka-persistence-message":"akka.persistence.serialization.MessageSerializer","akka-persistence-snapshot":"akka.persistence.serialization.SnapshotSerializer","akka-pubsub":"akka.contrib.pattern.protobuf.DistributedPubSubMessageSerializer","bytes":"akka.serialization.ByteArraySerializer","daemon-create":"akka.remote.serialization.DaemonMsgCreateSerializer","java":"akka.serialization.JavaSerializer","proto":"akka.remote.serialization.ProtobufSerializer"},"typed":{"timeout":"5s"},"unstarted-push-timeout":"10s"},"cluster":{"auto-down":"off","auto-down-unreachable-after":"10s","failure-detector":{"acceptable-heartbeat-pause":"3
> s","expected-response-after":"5 s","heartbeat-interval":"1
> s","implementation-class":"akka.remote.PhiAccrualFailureDetector","max-sample-size":1000,"min-std-deviation":"100
>
> ms","monitored-by-nr-of-members":5,"threshold":8},"gossip-different-view-probability":0.8,"gossip-interval":"1s","gossip-time-to-live":"2s","jmx":{"enabled":"on"},"leader-actions-interval":"1s","log-info":"on","metrics":{"collect-interval":"3s","collector-class":"akka.cluster.SigarMetricsCollector","enabled":"on","gossip-interval":"3s","moving-average-half-life":"12s"},"min-nr-of-members":1,"periodic-tasks-initial-delay":"1s","publish-stats-interval":"off","reduce-gossip-different-view-probability":400,"retry-unsuccessful-join-after":"10s","role":{},"roles":[],"scheduler":{"tick-duration":"33ms","ticks-per-wheel":512},"seed-node-timeout":"5s","seed-nodes":["akka.tcp://[email protected]:2551"],"unreachable-nodes-reaper-interval":"1s","use-dispatcher":""},"contrib":{"cluster":{"client":{"mailbox":{"mailbox-type":"akka.dispatch.UnboundedDequeBasedMailbox","stash-capacity":1000}},"pub-sub":{"gossip-interval":"1s","max-delta-elements":3000,"name":"distributedPubSubMediator","removed-time-to-live":"120s","role":"","routing-logic":"random"},"receptionist":{"name":"receptionist","number-of-contacts":3,"response-tunnel-receive-timeout":"30s","role":""},"sharding":{"buffer-size":100000,"coordinator-failure-backoff":"10
> s","guardian-name":"sharding","handoff-timeout":"60
> s","least-shard-allocation-strategy":{"max-simultaneous-rebalance":3,"rebalance-threshold":10},"rebalance-interval":"10
> s","retry-interval":"2 s","role":"","snapshot-interval":"3600
> s"}}},"daemonic":"off","extensions":[],"home":"","io":{"pinned-dispatcher":{"executor":"thread-pool-executor","thread-pool-executor":{"allow-core-pool-timeout":"off"},"type":"PinnedDispatcher"},"tcp":{"batch-accept-limit":10,"direct-buffer-pool-limit":1000,"direct-buffer-size":"128
>
> KiB","file-io-dispatcher":"akka.actor.default-dispatcher","file-io-transferTo-limit":"512
>
> KiB","finish-connect-retries":5,"management-dispatcher":"akka.actor.default-dispatcher","max-channels":256000,"max-received-message-size":"unlimited","nr-of-selectors":1,"register-timeout":"5s","selector-association-retries":10,"selector-dispatcher":"akka.io.pinned-dispatcher","trace-logging":"off","windows-connection-abort-workaround-enabled":"auto","worker-dispatcher":"akka.actor.default-dispatcher"},"udp":{"direct-buffer-pool-limit":1000,"direct-buffer-size":"128
>
> KiB","management-dispatcher":"akka.actor.default-dispatcher","max-channels":4096,"nr-of-selectors":1,"receive-throughput":3,"received-message-size-limit":"unlimited","select-timeout":"infinite","selector-association-retries":10,"selector-dispatcher":"akka.io.pinned-dispatcher","trace-logging":"off","worker-dispatcher":"akka.actor.default-dispatcher"},"udp-connected":{"direct-buffer-pool-limit":1000,"direct-buffer-size":"128
>
> KiB","management-dispatcher":"akka.actor.default-dispatcher","max-channels":4096,"nr-of-selectors":1,"receive-throughput":3,"received-message-size-limit":"unlimited","select-timeout":"infinite","selector-association-retries":10,"selector-dispatcher":"akka.io.pinned-dispatcher","trace-logging":"off","worker-dispatcher":"akka.actor.default-dispatcher"}},"jvm-exit-on-fatal-error":"on","log-config-on-start":"off","log-dead-letters":10,"log-dead-letters-during-shutdown":"on","logger-startup-timeout":"5s","loggers":["akka.event.Logging$DefaultLogger"],"loglevel":"INFO","persistence":{"at-least-once-delivery":{"max-unconfirmed-messages":100000,"redeliver-interval":"5s","warn-after-number-of-unconfirmed-attempts":5},"dispatchers":{"default-plugin-dispatcher":{"executor":"thread-pool-executor","type":"PinnedDispatcher"},"default-replay-dispatcher":{"executor":"fork-join-executor","fork-join-executor":{"parallelism-max":8,"parallelism-min":2},"type":"Dispatcher"},"default-stream-dispatcher":{"executor":"fork-join-executor","fork-join-executor":{"parallelism-max":8,"parallelism-min":2},"type":"Dispatcher"}},"journal":{"inmem":{"class":"akka.persistence.journal.inmem.InmemJournal","plugin-dispatcher":"akka.actor.default-dispatcher"},"leveldb":{"checksum":"off","class":"akka.persistence.journal.leveldb.LeveldbJournal","dir":"journal","fsync":"on","native":"on","plugin-dispatcher":"akka.persistence.dispatchers.default-plugin-dispatcher","replay-dispatcher":"akka.persistence.dispatchers.default-replay-dispatcher"},"leveldb-shared":{"class":"akka.persistence.journal.leveldb.SharedLeveldbJournal","plugin-dispatcher":"akka.actor.default-dispatcher","store":{"checksum":"off","dir":"journal","fsync":"on","native":"on","replay-dispatcher":"akka.persistence.dispatchers.default-plugin-dispatcher","store-dispatcher":"akka.persistence.dispatchers.default-plugin-dispatcher"},"timeout":"10s"},"max-confirmation-batch-size":10000,"max-deletion-batch-size":10000,"max-message-batch-size":200,"plugin":"cassandra-journal"},"snapshot-store":{"local":{"class":"akka.persistence.snapshot.local.LocalSnapshotStore","dir":"snapshots","plugin-dispatcher":"akka.persistence.dispatchers.default-plugin-dispatcher","stream-dispatcher":"akka.persistence.dispatchers.default-stream-dispatcher"},"plugin":"cassandra-snapshot-store"},"view":{"auto-update":"on","auto-update-interval":"5s","auto-update-replay-max":-1}},"remote":{"adapters":{"gremlin":"akka.remote.transport.FailureInjectorProvider","trttl":"akka.remote.transport.ThrottlerProvider"},"backoff-interval":"5
>
> ms","backoff-remote-dispatcher":{"executor":"fork-join-executor","fork-join-executor":{"parallelism-max":2,"parallelism-min":2},"type":"Dispatcher"},"command-ack-timeout":"30
>
> s","default-remote-dispatcher":{"executor":"fork-join-executor","fork-join-executor":{"parallelism-max":2,"parallelism-min":2},"type":"Dispatcher"},"enabled-transports":["akka.remote.netty.tcp"],"flush-wait-on-shutdown":"2
> s","gremlin":{"debug":"off"},"initial-system-message-delivery-timeout":"3
> m","log-buffer-size-exceeding":50000,"log-frame-size-exceeding":"off","log-received-messages":"off","log-remote-lifecycle-events":"off","log-sent-messages":"off","netty":{"ssl":{"applied-adapters":[],"backlog":4096,"client-socket-worker-pool":{"pool-size-factor":1,"pool-size-max":2,"pool-size-min":2},"connection-timeout":"15
>
> s","enable-ssl":true,"hostname":"","maximum-frame-size":"128000b","port":2552,"receive-buffer-size":"256000b","security":{"enabled-algorithms":["TLS_RSA_WITH_AES_128_CBC_SHA"],"key-password":"changeme","key-store":"keystore","key-store-password":"changeme","protocol":"TLSv1","random-number-generator":"","trust-store":"truststore","trust-store-password":"changeme"},"send-buffer-size":"256000b","server-socket-worker-pool":{"pool-size-factor":1,"pool-size-max":2,"pool-size-min":2},"tcp-keepalive":"on","tcp-nodelay":"on","tcp-reuse-addr":"off-for-windows","transport-class":"akka.remote.transport.netty.NettyTransport","transport-protocol":"tcp","use-dispatcher-for-io":"","write-buffer-high-water-mark":"0b","write-buffer-low-water-mark":"0b"},"tcp":{"applied-adapters":[],"backlog":4096,"client-socket-worker-pool":{"pool-size-factor":1,"pool-size-max":2,"pool-size-min":2},"connection-timeout":"15
>
> s","enable-ssl":false,"hostname":"127.0.0.1","maximum-frame-size":"128000b","port":2551,"receive-buffer-size":"256000b","send-buffer-size":"256000b","server-socket-worker-pool":{"pool-size-factor":1,"pool-size-max":2,"pool-size-min":2},"tcp-keepalive":"on","tcp-nodelay":"on","tcp-reuse-addr":"off-for-windows","transport-class":"akka.remote.transport.netty.NettyTransport","transport-protocol":"tcp","use-dispatcher-for-io":"","write-buffer-high-water-mark":"0b","write-buffer-low-water-mark":"0b"},"udp":{"applied-adapters":[],"backlog":4096,"client-socket-worker-pool":{"pool-size-factor":1,"pool-size-max":2,"pool-size-min":2},"connection-timeout":"15
>
> s","enable-ssl":false,"hostname":"","maximum-frame-size":"128000b","port":2552,"receive-buffer-size":"256000b","send-buffer-size":"256000b","server-socket-worker-pool":{"pool-size-factor":1,"pool-size-max":2,"pool-size-min":2},"tcp-keepalive":"on","tcp-nodelay":"on","tcp-reuse-addr":"off-for-windows","transport-class":"akka.remote.transport.netty.NettyTransport","transport-protocol":"udp","use-dispatcher-for-io":"","write-buffer-high-water-mark":"0b","write-buffer-low-water-mark":"0b"}},"prune-quarantine-marker-after":"5
> d","require-cookie":"off","resend-interval":"2 s","retry-gate-closed-for":"5
> s","secure-cookie":"","shutdown-timeout":"10 s","startup-timeout":"10
> s","system-message-ack-piggyback-timeout":"0.3
> s","system-message-buffer-size":1000,"transport-failure-detector":{"acceptable-heartbeat-pause":"20
> s","heartbeat-interval":"4
> s","implementation-class":"akka.remote.DeadlineFailureDetector"},"trusted-selection-paths":[],"untrusted-mode":"off","use-dispatcher":"akka.remote.default-remote-dispatcher","use-passive-connections":"on","watch-failure-detector":{"acceptable-heartbeat-pause":"10
> s","expected-response-after":"3 s","heartbeat-interval":"1
> s","implementation-class":"akka.remote.PhiAccrualFailureDetector","max-sample-size":200,"min-std-deviation":"100
>
> ms","threshold":10,"unreachable-nodes-reaper-interval":"1s"}},"scheduler":{"implementation":"akka.actor.LightArrayRevolverScheduler","shutdown-timeout":"5s","tick-duration":"10ms","ticks-per-wheel":512},"stdout-loglevel":"WARNING","version":"2.3.9"},"awt":{"toolkit":"sun.lwawt.macosx.LWCToolkit"},"cassandra-journal":{"class":"akka.persistence.cassandra.journal.CassandraJournal","configure-keyspace":true,"configure-table":true,"contact-points":["127.0.0.1"],"keyspace":"akka","keyspace-autocreate":false,"keyspace-strategyClass":"SimpleStrategy","keyspace-strategyClass-DC1":"DC1","keyspace-strategyClass-DC1-replication-factor":1,"keyspace-strategyClass-DC2":"DC2","keyspace-strategyClass-DC2-replication-factor":1,"max-partition-size":5000000,"max-result-size":50001,"plugin-dispatcher":"akka.actor.default-dispatcher","port":7104,"read-consistency":"QUORUM","replay-dispatcher":"akka.persistence.dispatchers.default-replay-dispatcher","replication-factor":1,"table":"messages","write-consistency":"QUORUM"},"cassandra-snapshot-store":{"class":"akka.persistence.cassandra.snapshot.CassandraSnapshotStore","configure-keyspace":true,"configure-table":true,"contact-points":["127.0.0.1"],"default-dispatcher":{"executor":"fork-join-executor","fork-join-executor":{"parallelism-max":8,"parallelism-min":2},"type":"Dispatcher"},"keyspace":"akka_snapshot","keyspace-autocreate":false,"keyspace-strategyClass":"SimpleStrategy","keyspace-strategyClass-DC1":"DC1","keyspace-strategyClass-DC1-replication-factor":1,"keyspace-strategyClass-DC2":"DC2","keyspace-strategyClass-DC2-replication-factor":1,"max-metadata-result-size":10,"plugin-dispatcher":"cassandra-snapshot-store.default-dispatcher","port":7104,"read-consistency":"ONE","replication-factor":1,"table":"snapshots","write-consistency":"ONE"})
>
>
> [INFO] [05/27/2015 14:47:39.910] [main] [Remoting] Starting remoting
> [INFO] [05/27/2015 14:47:40.089] [main] [Remoting] Remoting started;
> listening on addresses :[akka.tcp://[email protected]:2551]
> [INFO] [05/27/2015 14:47:40.103] [main] [Cluster(akka://default)] Cluster
> Node [akka.tcp://[email protected]:2551] - Starting up...
> [INFO] [05/27/2015 14:47:40.125] [main] [Cluster(akka://default)] Cluster
> Node [akka.tcp://[email protected]:2551] - Registered cluster JMX MBean
> [akka:type=Cluster]
> [INFO] [05/27/2015 14:47:40.125] [main] [Cluster(akka://default)] Cluster
> Node [akka.tcp://[email protected]:2551] - Started up successfully
> [INFO] [05/27/2015 14:47:40.134] [default-akka.actor.default-dispatcher-4]
> [Cluster(akka://default)] 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] [05/27/2015 14:47:40.138] [default-akka.actor.default-dispatcher-4]
> [Cluster(akka://default)] Cluster Node [akka.tcp://[email protected]:2551] -
> Metrics collection has started successfully
> [INFO] [05/27/2015 14:47:40.149] [default-akka.actor.default-dispatcher-14]
> [Cluster(akka://default)] Cluster Node [akka.tcp://[email protected]:2551] -
> Node [akka.tcp://[email protected]:2551] is JOINING, roles []
>
>
> [INFO] [05/27/2015 14:47:41.154] [default-akka.actor.default-dispatcher-3]
> [Cluster(akka://default)] Cluster Node [akka.tcp://[email protected]:2551] -
> Leader is moving node [akka.tcp://[email protected]:2551] to [Up]
> [INFO] [05/27/2015 14:47:47.474] [default-akka.actor.default-dispatcher-20]
> [akka.tcp://[email protected]:2551/user/$c] MemberUp(Member(address =
> akka.tcp://[email protected]:2551, status = Up))
> [INFO] [05/27/2015 14:47:47.478] [default-akka.actor.default-dispatcher-2]
> [akka.tcp://[email protected]:2551/user/sharding/ClusterTestCoordinator]
> Singleton manager [akka.tcp://[email protected]:2551] starting singleton actor
> [INFO] [05/27/2015 14:47:47.480] [default-akka.actor.default-dispatcher-23]
> [akka://default/user/sharding/ClusterTestCoordinator/singleton/coordinator]
> Message [akka.contrib.pattern.ShardCoordinator$Internal$Register] from
> Actor[akka://default/user/sharding/ClusterTest#-1153239803] to
> Actor[akka://default/user/sharding/ClusterTestCoordinator/singleton/coordinator]
> was not delivered. [1] dead letters encountered. This logging can be turned
> off or adjusted with configuration settings 'akka.log-dead-letters' and
> 'akka.log-dead-letters-during-shutdown'.
> [INFO] [05/27/2015 14:47:47.480] [default-akka.actor.default-dispatcher-2]
> [akka.tcp://[email protected]:2551/user/sharding/ClusterTestCoordinator]
> ClusterSingletonManager state change [Start -> Oldest]
> [INFO] [05/27/2015 14:47:47.481] [default-akka.actor.default-dispatcher-23]
> [akka://default/user/sharding/ClusterTestCoordinator/singleton/coordinator]
> Message [akka.contrib.pattern.ShardCoordinator$Internal$Register] from
> Actor[akka://default/user/sharding/ClusterTest#-1153239803] to
> Actor[akka://default/user/sharding/ClusterTestCoordinator/singleton/coordinator]
> was not delivered. [2] dead letters encountered. This logging can be turned
> off or adjusted with configuration settings 'akka.log-dead-letters' and
> 'akka.log-dead-letters-during-shutdown'.
>
>
> [INFO] [05/27/2015 14:47:41.154] [default-akka.actor.default-dispatcher-3]
> [Cluster(akka://default)] Cluster Node [akka.tcp://[email protected]:2551] -
> Leader is moving node [akka.tcp://[email protected]:2551] to [Up]
> [INFO] [05/27/2015 14:47:47.474] [default-akka.actor.default-dispatcher-20]
> [akka.tcp://[email protected]:2551/user/$c] MemberUp(Member(address =
> akka.tcp://[email protected]:2551, status = Up))
> [INFO] [05/27/2015 14:47:47.478] [default-akka.actor.default-dispatcher-2]
> [akka.tcp://[email protected]:2551/user/sharding/ClusterTestCoordinator]
> Singleton manager [akka.tcp://[email protected]:2551] starting singleton actor
> [INFO] [05/27/2015 14:47:47.480] [default-akka.actor.default-dispatcher-23]
> [akka://default/user/sharding/ClusterTestCoordinator/singleton/coordinator]
> Message [akka.contrib.pattern.ShardCoordinator$Internal$Register] from
> Actor[akka://default/user/sharding/ClusterTest#-1153239803] to
> Actor[akka://default/user/sharding/ClusterTestCoordinator/singleton/coordinator]
> was not delivered. [1] dead letters encountered. This logging can be turned
> off or adjusted with configuration settings 'akka.log-dead-letters' and
> 'akka.log-dead-letters-during-shutdown'.
> [INFO] [05/27/2015 14:47:47.480] [default-akka.actor.default-dispatcher-2]
> [akka.tcp://[email protected]:2551/user/sharding/ClusterTestCoordinator]
> ClusterSingletonManager state change [Start -> Oldest]
> [INFO] [05/27/2015 14:47:47.481] [default-akka.actor.default-dispatcher-23]
> [akka://default/user/sharding/ClusterTestCoordinator/singleton/coordinator]
> Message [akka.contrib.pattern.ShardCoordinator$Internal$Register] from
> Actor[akka://default/user/sharding/ClusterTest#-1153239803] to
> Actor[akka://default/user/sharding/ClusterTestCoordinator/singleton/coordinator]
> was not delivered. [2] dead letters encountered. This logging can be turned
> off or adjusted with configuration settings 'akka.log-dead-letters' and
> 'akka.log-dead-letters-during-shutdown'.
> 2015-05-27 14:47:47.503 ERROR 35270 --- [ main]
> o.apache.cassandra.cql3.QueryProcessor : Unable to initialize MemoryMeter
> (jamm not specified as javaagent). This means Cassandra will be unable to
> measure object sizes accurately and may consequently OOM.
> 2015-05-27 14:47:47.525 WARN 35270 --- [t-dispatcher-31]
> c.datastax.driver.core.FrameCompressor : Error loading LZ4 library
> (java.lang.NoSuchMethodError:
> net.jpountz.lz4.LZ4Factory.fastDecompressor()Lnet/jpountz/lz4/LZ4FastDecompressor;).
> LZ4 compression will not be available for the protocol.
> [ERROR] [05/27/2015 14:47:47.918] [default-akka.actor.default-dispatcher-2]
> [akka://default/system/snapshot-store] All host(s) tried for query failed
> (tried: /127.0.0.1:7104 (com.datastax.driver.core.TransportException:
> [/127.0.0.1:7104] Cannot connect))
> akka.actor.ActorInitializationException: exception during creation
> at akka.actor.ActorInitializationException$.apply(Actor.scala:164)
> at akka.actor.ActorCell.create(ActorCell.scala:596)
> at akka.actor.ActorCell.invokeAll$1(ActorCell.scala:456)
> at akka.actor.ActorCell.systemInvoke(ActorCell.scala:478)
> at akka.dispatch.Mailbox.processAllSystemMessages(Mailbox.scala:279)
> at akka.dispatch.Mailbox.run(Mailbox.scala:220)
> at akka.dispatch.Mailbox.exec(Mailbox.scala:231)
> at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
> at
> scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
> at
> scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
> at
> scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
> Caused by: com.datastax.driver.core.exceptions.NoHostAvailableException: All
> host(s) tried for query failed (tried: /127.0.0.1:7104
> (com.datastax.driver.core.TransportException: [/127.0.0.1:7104] Cannot
> connect))
> at
> com.datastax.driver.core.ControlConnection.reconnectInternal(ControlConnection.java:193)
> at
> com.datastax.driver.core.ControlConnection.connect(ControlConnection.java:79)
> at com.datastax.driver.core.Cluster$Manager.init(Cluster.java:1148)
> at com.datastax.driver.core.Cluster.init(Cluster.java:149)
> at com.datastax.driver.core.Cluster.connect(Cluster.java:225)
> at
> akka.persistence.cassandra.snapshot.CassandraSnapshotStore.<init>(CassandraSnapshotStore.scala:71)
> at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
> at
> sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62)
> at
> sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
> at java.lang.reflect.Constructor.newInstance(Constructor.java:408)
> at java.lang.Class.newInstance(Class.java:438)
> at akka.util.Reflect$.instantiate(Reflect.scala:45)
> at akka.actor.NoArgsReflectConstructor.produce(Props.scala:361)
> at akka.actor.Props.newActor(Props.scala:252)
> at akka.actor.ActorCell.newActor(ActorCell.scala:552)
> at akka.actor.ActorCell.create(ActorCell.scala:578)
> ... 9 more
>
> [ERROR] [05/27/2015 14:47:47.920] [default-akka.actor.default-dispatcher-2]
> [akka://default/system/journal] All host(s) tried for query failed (tried:
> /127.0.0.1:7104 (com.datastax.driver.core.TransportException:
> [/127.0.0.1:7104] Cannot connect))
> akka.actor.ActorInitializationException: exception during creation
> at akka.actor.ActorInitializationException$.apply(Actor.scala:164)
> at akka.actor.ActorCell.create(ActorCell.scala:596)
> at akka.actor.ActorCell.invokeAll$1(ActorCell.scala:456)
> at akka.actor.ActorCell.systemInvoke(ActorCell.scala:478)
> at akka.dispatch.Mailbox.processAllSystemMessages(Mailbox.scala:279)
> at akka.dispatch.Mailbox.run(Mailbox.scala:220)
> at akka.dispatch.Mailbox.exec(Mailbox.scala:231)
> at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
> at
> scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
> at
> scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
> at
> scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
> Caused by: com.datastax.driver.core.exceptions.NoHostAvailableException: All
> host(s) tried for query failed (tried: /127.0.0.1:7104
> (com.datastax.driver.core.TransportException: [/127.0.0.1:7104] Cannot
>
> ...
--
>>>>>>>>>> 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 you are subscribed to the Google Groups "Akka
User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email
to [email protected].
To post to this group, send email to [email protected].
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
