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 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.journal.CassandraJournal.<init>(CassandraJournal.scala:27)
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
[INFO] [05/27/2015 14:47:47.925] [default-akka.actor.default-dispatcher-24]
[akka://default/system/snapshot-store] Message
[akka.persistence.SnapshotProtocol$LoadSnapshot] from
Actor[akka://default/user/sharding/ClusterTestCoordinator/singleton/coordinator#-2067944171]
to Actor[akka://default/system/snapshot-store#-2059360564] was not delivered.
[3] 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.932 INFO 35270 --- [ main]
o.apache.cassandra.service.CacheService : Initializing key cache with capacity
of 28 MBs.
2015-05-27 14:47:47.932 WARN 35270 --- [ main]
o.apache.cassandra.service.CacheService : MemoryMeter uninitialized (jamm not
specified as java agent); KeyCache size in JVM Heap will not be calculated
accurately. Usually this means cassandra-env.sh disabled jamm because you are
using a buggy JRE; upgrade to the Sun JRE instead
2015-05-27 14:47:47.940 INFO 35270 --- [ main]
o.apache.cassandra.service.CacheService : Scheduling key cache save to each
14400 seconds (going to save all keys).
2015-05-27 14:47:47.941 INFO 35270 --- [ main]
o.apache.cassandra.service.CacheService : Initializing row cache with capacity
of 0 MBs and provider org.apache.cassandra.cache.SerializingCacheProvider
2015-05-27 14:47:47.946 INFO 35270 --- [ main]
o.apache.cassandra.service.CacheService : Scheduling row cache save to each 0
seconds (going to save all keys).
2015-05-27 14:47:48.015 INFO 35270 --- [ main]
o.apache.cassandra.db.ColumnFamilyStore : Initializing system.hints
2015-05-27 14:47:48.032 INFO 35270 --- [ main]
o.apache.cassandra.db.ColumnFamilyStore : Initializing system.NodeIdInfo
2015-05-27 14:47:48.033 INFO 35270 --- [ main]
o.apache.cassandra.db.ColumnFamilyStore : Initializing system.Migrations
2015-05-27 14:47:48.035 INFO 35270 --- [ main]
o.apache.cassandra.db.ColumnFamilyStore : Initializing system.Schema
2015-05-27 14:47:48.036 INFO 35270 --- [ main]
o.apache.cassandra.db.ColumnFamilyStore : Initializing system.peers
2015-05-27 14:47:48.037 INFO 35270 --- [ main]
o.apache.cassandra.db.ColumnFamilyStore : Initializing
system.schema_columnfamilies
2015-05-27 14:47:48.041 INFO 35270 --- [ableBatchOpen:2]
o.a.cassandra.io.sstable.SSTableReader : Opening
build/cassandra-test/data/system/schema_columnfamilies/system-schema_columnfamilies-ic-47
(4580 bytes)
2015-05-27 14:47:48.041 INFO 35270 --- [ableBatchOpen:1]
o.a.cassandra.io.sstable.SSTableReader : Opening
build/cassandra-test/data/system/schema_columnfamilies/system-schema_columnfamilies-ic-46
(4585 bytes)
2015-05-27 14:47:48.041 INFO 35270 --- [ableBatchOpen:3]
o.a.cassandra.io.sstable.SSTableReader : Opening
build/cassandra-test/data/system/schema_columnfamilies/system-schema_columnfamilies-ic-48
(4588 bytes)
2015-05-27 14:47:48.042 INFO 35270 --- [ableBatchOpen:2]
o.a.cassandra.io.sstable.SSTableReader : Opening
build/cassandra-test/data/system/schema_columnfamilies/system-schema_columnfamilies-ic-47
(4580 bytes)
2015-05-27 14:47:48.042 INFO 35270 --- [ableBatchOpen:1]
o.a.cassandra.io.sstable.SSTableReader : Opening
build/cassandra-test/data/system/schema_columnfamilies/system-schema_columnfamilies-ic-46
(4585 bytes)
2015-05-27 14:47:48.042 INFO 35270 --- [ableBatchOpen:3]
o.a.cassandra.io.sstable.SSTableReader : Opening
build/cassandra-test/data/system/schema_columnfamilies/system-schema_columnfamilies-ic-48
(4588 bytes)
2015-05-27 14:47:48.074 INFO 35270 --- [ main]
o.apache.cassandra.db.ColumnFamilyStore : Initializing system.IndexInfo
2015-05-27 14:47:48.076 INFO 35270 --- [ main]
o.apache.cassandra.db.ColumnFamilyStore : Initializing system.local
2015-05-27 14:47:48.077 INFO 35270 --- [ableBatchOpen:1]
o.a.cassandra.io.sstable.SSTableReader : Opening
build/cassandra-test/data/system/local/system-local-ic-214 (121 bytes)
2015-05-27 14:47:48.077 INFO 35270 --- [ableBatchOpen:2]
o.a.cassandra.io.sstable.SSTableReader : Opening
build/cassandra-test/data/system/local/system-local-ic-213 (420 bytes)
2015-05-27 14:47:48.077 INFO 35270 --- [ableBatchOpen:1]
o.a.cassandra.io.sstable.SSTableReader : Opening
build/cassandra-test/data/system/local/system-local-ic-214 (121 bytes)
2015-05-27 14:47:48.077 INFO 35270 --- [ableBatchOpen:3]
o.a.cassandra.io.sstable.SSTableReader : Opening
build/cassandra-test/data/system/local/system-local-ic-215 (90 bytes)
2015-05-27 14:47:48.077 INFO 35270 --- [ableBatchOpen:2]
o.a.cassandra.io.sstable.SSTableReader : Opening
build/cassandra-test/data/system/local/system-local-ic-213 (420 bytes)
2015-05-27 14:47:48.077 INFO 35270 --- [ableBatchOpen:3]
o.a.cassandra.io.sstable.SSTableReader : Opening
build/cassandra-test/data/system/local/system-local-ic-215 (90 bytes)
2015-05-27 14:47:48.080 INFO 35270 --- [ main]
o.a.cassandra.cache.AutoSavingCache : reading saved cache
build/cassandra-test/saved_caches/system-local-KeyCache-b.db
2015-05-27 14:47:48.083 INFO 35270 --- [ main]
o.apache.cassandra.db.ColumnFamilyStore : Initializing system.schema_columns
2015-05-27 14:47:48.084 INFO 35270 --- [ableBatchOpen:1]
o.a.cassandra.io.sstable.SSTableReader : Opening
build/cassandra-test/data/system/schema_columns/system-schema_columns-ic-48
(4188 bytes)
2015-05-27 14:47:48.084 INFO 35270 --- [ableBatchOpen:1]
o.a.cassandra.io.sstable.SSTableReader : Opening
build/cassandra-test/data/system/schema_columns/system-schema_columns-ic-48
(4188 bytes)
2015-05-27 14:47:48.085 INFO 35270 --- [ableBatchOpen:3]
o.a.cassandra.io.sstable.SSTableReader : Opening
build/cassandra-test/data/system/schema_columns/system-schema_columns-ic-47
(4187 bytes)
2015-05-27 14:47:48.085 INFO 35270 --- [ableBatchOpen:2]
o.a.cassandra.io.sstable.SSTableReader : Opening
build/cassandra-test/data/system/schema_columns/system-schema_columns-ic-46
(4190 bytes)
2015-05-27 14:47:48.085 INFO 35270 --- [ableBatchOpen:3]
o.a.cassandra.io.sstable.SSTableReader : Opening
build/cassandra-test/data/system/schema_columns/system-schema_columns-ic-47
(4187 bytes)
2015-05-27 14:47:48.086 INFO 35270 --- [ableBatchOpen:2]
o.a.cassandra.io.sstable.SSTableReader : Opening
build/cassandra-test/data/system/schema_columns/system-schema_columns-ic-46
(4190 bytes)
2015-05-27 14:47:48.089 INFO 35270 --- [ main]
o.apache.cassandra.db.ColumnFamilyStore : Initializing system.batchlog
2015-05-27 14:47:48.090 INFO 35270 --- [ main]
o.apache.cassandra.db.ColumnFamilyStore : Initializing system.LocationInfo
2015-05-27 14:47:48.091 INFO 35270 --- [ main]
o.apache.cassandra.db.ColumnFamilyStore : Initializing system.peer_events
2015-05-27 14:47:48.092 INFO 35270 --- [ main]
o.apache.cassandra.db.ColumnFamilyStore : Initializing system.HintsColumnFamily
2015-05-27 14:47:48.092 INFO 35270 --- [ main]
o.apache.cassandra.db.ColumnFamilyStore : Initializing system.range_xfers
2015-05-27 14:47:48.094 INFO 35270 --- [ main]
o.apache.cassandra.db.ColumnFamilyStore : Initializing system.schema_keyspaces
2015-05-27 14:47:48.095 INFO 35270 --- [ableBatchOpen:1]
o.a.cassandra.io.sstable.SSTableReader : Opening
build/cassandra-test/data/system/schema_keyspaces/system-schema_keyspaces-ic-47
(219 bytes)
2015-05-27 14:47:48.095 INFO 35270 --- [ableBatchOpen:2]
o.a.cassandra.io.sstable.SSTableReader : Opening
build/cassandra-test/data/system/schema_keyspaces/system-schema_keyspaces-ic-48
(222 bytes)
2015-05-27 14:47:48.095 INFO 35270 --- [ableBatchOpen:1]
o.a.cassandra.io.sstable.SSTableReader : Opening
build/cassandra-test/data/system/schema_keyspaces/system-schema_keyspaces-ic-47
(219 bytes)
2015-05-27 14:47:48.095 INFO 35270 --- [ableBatchOpen:3]
o.a.cassandra.io.sstable.SSTableReader : Opening
build/cassandra-test/data/system/schema_keyspaces/system-schema_keyspaces-ic-46
(274 bytes)
2015-05-27 14:47:48.095 INFO 35270 --- [ableBatchOpen:2]
o.a.cassandra.io.sstable.SSTableReader : Opening
build/cassandra-test/data/system/schema_keyspaces/system-schema_keyspaces-ic-48
(222 bytes)
2015-05-27 14:47:48.095 INFO 35270 --- [ableBatchOpen:3]
o.a.cassandra.io.sstable.SSTableReader : Opening
build/cassandra-test/data/system/schema_keyspaces/system-schema_keyspaces-ic-46
(274 bytes)
2015-05-27 14:47:48.434 INFO 35270 --- [ main]
o.apache.cassandra.db.ColumnFamilyStore : Initializing system_traces.sessions
2015-05-27 14:47:48.435 INFO 35270 --- [ main]
o.apache.cassandra.db.ColumnFamilyStore : Initializing system_traces.events
2015-05-27 14:47:48.436 INFO 35270 --- [ main]
o.a.cassandra.service.CassandraDaemon : completed pre-loading (3 keys) key
cache.
2015-05-27 14:47:48.442 INFO 35270 --- [ main]
o.a.cassandra.db.commitlog.CommitLog : Replaying
build/cassandra-test/commitlog/CommitLog-2-1432760949918.log,
build/cassandra-test/commitlog/CommitLog-2-1432760949919.log,
build/cassandra-test/commitlog/CommitLog-2-1432760949920.log,
build/cassandra-test/commitlog/CommitLog-2-1432760949921.log,
build/cassandra-test/commitlog/CommitLog-2-1432760949922.log,
build/cassandra-test/commitlog/CommitLog-2-1432760949923.log,
build/cassandra-test/commitlog/CommitLog-2-1432760949924.log,
build/cassandra-test/commitlog/CommitLog-2-1432760949925.log,
build/cassandra-test/commitlog/CommitLog-2-1432760949926.log,
build/cassandra-test/commitlog/CommitLog-2-1432760949927.log,
build/cassandra-test/commitlog/CommitLog-2-1432760949928.log,
build/cassandra-test/commitlog/CommitLog-2-1432760949929.log,
build/cassandra-test/commitlog/CommitLog-2-1432760949930.log,
build/cassandra-test/commitlog/CommitLog-2-1432760949931.log,
build/cassandra-test/commitlog/CommitLog-2-1432760949932.log,
build/cassandra-test/commitlog/CommitLog-2-1432760949933.log,
build/cassandra-test/commitlog/CommitLog-2-1432760949934.log,
build/cassandra-test/commitlog/CommitLog-2-1432760949935.log,
build/cassandra-test/commitlog/CommitLog-2-1432760949936.log,
build/cassandra-test/commitlog/CommitLog-2-1432760949937.log,
build/cassandra-test/commitlog/CommitLog-2-1432760949938.log,
build/cassandra-test/commitlog/CommitLog-2-1432760949939.log,
build/cassandra-test/commitlog/CommitLog-2-1432760949940.log,
build/cassandra-test/commitlog/CommitLog-2-1432760949941.log,
build/cassandra-test/commitlog/CommitLog-2-1432760949942.log,
build/cassandra-test/commitlog/CommitLog-2-1432760949943.log,
build/cassandra-test/commitlog/CommitLog-2-1432760949944.log,
build/cassandra-test/commitlog/CommitLog-2-1432760949945.log,
build/cassandra-test/commitlog/CommitLog-2-1432760949946.log,
build/cassandra-test/commitlog/CommitLog-2-1432760949947.log,
build/cassandra-test/commitlog/CommitLog-2-1432760949948.log,
build/cassandra-test/commitlog/CommitLog-2-1432760949949.log,
build/cassandra-test/commitlog/CommitLog-2-1432760949950.log
2015-05-27 14:47:48.450 INFO 35270 --- [ main]
o.a.c.db.commitlog.CommitLogReplayer : Replaying
build/cassandra-test/commitlog/CommitLog-2-1432760949918.log
2015-05-27 14:47:48.488 INFO 35270 --- [ main]
o.a.c.db.commitlog.CommitLogReplayer : Finished reading
build/cassandra-test/commitlog/CommitLog-2-1432760949918.log
2015-05-27 14:47:48.489 INFO 35270 --- [ main]
o.a.c.db.commitlog.CommitLogReplayer : Replaying
build/cassandra-test/commitlog/CommitLog-2-1432760949919.log
2015-05-27 14:47:48.489 INFO 35270 --- [ main]
o.a.c.db.commitlog.CommitLogReplayer : Finished reading
build/cassandra-test/commitlog/CommitLog-2-1432760949919.log
2015-05-27 14:47:48.490 INFO 35270 --- [ main]
o.a.c.db.commitlog.CommitLogReplayer : Replaying
build/cassandra-test/commitlog/CommitLog-2-1432760949920.log
2015-05-27 14:47:48.490 INFO 35270 --- [ main]
o.a.c.db.commitlog.CommitLogReplayer : Finished reading
build/cassandra-test/commitlog/CommitLog-2-1432760949920.log
2015-05-27 14:47:48.490 INFO 35270 --- [ main]
o.a.c.db.commitlog.CommitLogReplayer : Replaying
build/cassandra-test/commitlog/CommitLog-2-1432760949921.log
2015-05-27 14:47:48.491 INFO 35270 --- [ main]
o.a.c.db.commitlog.CommitLogReplayer : Finished reading
build/cassandra-test/commitlog/CommitLog-2-1432760949921.log
2015-05-27 14:47:48.491 INFO 35270 --- [ main]
o.a.c.db.commitlog.CommitLogReplayer : Replaying
build/cassandra-test/commitlog/CommitLog-2-1432760949922.log
2015-05-27 14:47:48.492 INFO 35270 --- [ main]
o.a.c.db.commitlog.CommitLogReplayer : Finished reading
build/cassandra-test/commitlog/CommitLog-2-1432760949922.log
2015-05-27 14:47:48.492 INFO 35270 --- [ main]
o.a.c.db.commitlog.CommitLogReplayer : Replaying
build/cassandra-test/commitlog/CommitLog-2-1432760949923.log
2015-05-27 14:47:48.493 INFO 35270 --- [ main]
o.a.c.db.commitlog.CommitLogReplayer : Finished reading
build/cassandra-test/commitlog/CommitLog-2-1432760949923.log
2015-05-27 14:47:48.493 INFO 35270 --- [ main]
o.a.c.db.commitlog.CommitLogReplayer : Replaying
build/cassandra-test/commitlog/CommitLog-2-1432760949924.log
2015-05-27 14:47:48.494 INFO 35270 --- [ main]
o.a.c.db.commitlog.CommitLogReplayer : Finished reading
build/cassandra-test/commitlog/CommitLog-2-1432760949924.log
2015-05-27 14:47:48.494 INFO 35270 --- [ main]
o.a.c.db.commitlog.CommitLogReplayer : Replaying
build/cassandra-test/commitlog/CommitLog-2-1432760949925.log
2015-05-27 14:47:48.495 INFO 35270 --- [ main]
o.a.c.db.commitlog.CommitLogReplayer : Finished reading
build/cassandra-test/commitlog/CommitLog-2-1432760949925.log
2015-05-27 14:47:48.495 INFO 35270 --- [ main]
o.a.c.db.commitlog.CommitLogReplayer : Replaying
build/cassandra-test/commitlog/CommitLog-2-1432760949926.log
2015-05-27 14:47:48.495 INFO 35270 --- [ main]
o.a.c.db.commitlog.CommitLogReplayer : Finished reading
build/cassandra-test/commitlog/CommitLog-2-1432760949926.log
2015-05-27 14:47:48.496 INFO 35270 --- [ main]
o.a.c.db.commitlog.CommitLogReplayer : Replaying
build/cassandra-test/commitlog/CommitLog-2-1432760949927.log
2015-05-27 14:47:48.497 INFO 35270 --- [ main]
o.a.c.db.commitlog.CommitLogReplayer : Finished reading
build/cassandra-test/commitlog/CommitLog-2-1432760949927.log
2015-05-27 14:47:48.497 INFO 35270 --- [ main]
o.a.c.db.commitlog.CommitLogReplayer : Replaying
build/cassandra-test/commitlog/CommitLog-2-1432760949928.log
2015-05-27 14:47:48.497 INFO 35270 --- [ main]
o.a.c.db.commitlog.CommitLogReplayer : Finished reading
build/cassandra-test/commitlog/CommitLog-2-1432760949928.log
2015-05-27 14:47:48.498 INFO 35270 --- [ main]
o.a.c.db.commitlog.CommitLogReplayer : Replaying
build/cassandra-test/commitlog/CommitLog-2-1432760949929.log
2015-05-27 14:47:48.498 INFO 35270 --- [ main]
o.a.c.db.commitlog.CommitLogReplayer : Finished reading
build/cassandra-test/commitlog/CommitLog-2-1432760949929.log
2015-05-27 14:47:48.498 INFO 35270 --- [ main]
o.a.c.db.commitlog.CommitLogReplayer : Replaying
build/cassandra-test/commitlog/CommitLog-2-1432760949930.log
2015-05-27 14:47:48.499 INFO 35270 --- [ main]
o.a.c.db.commitlog.CommitLogReplayer : Finished reading
build/cassandra-test/commitlog/CommitLog-2-1432760949930.log
2015-05-27 14:47:48.500 INFO 35270 --- [ main]
o.a.c.db.commitlog.CommitLogReplayer : Replaying
build/cassandra-test/commitlog/CommitLog-2-1432760949931.log
2015-05-27 14:47:48.500 INFO 35270 --- [ main]
o.a.c.db.commitlog.CommitLogReplayer : Finished reading
build/cassandra-test/commitlog/CommitLog-2-1432760949931.log
2015-05-27 14:47:48.500 INFO 35270 --- [ main]
o.a.c.db.commitlog.CommitLogReplayer : Replaying
build/cassandra-test/commitlog/CommitLog-2-1432760949932.log
2015-05-27 14:47:48.501 INFO 35270 --- [ main]
o.a.c.db.commitlog.CommitLogReplayer : Finished reading
build/cassandra-test/commitlog/CommitLog-2-1432760949932.log
2015-05-27 14:47:48.501 INFO 35270 --- [ main]
o.a.c.db.commitlog.CommitLogReplayer : Replaying
build/cassandra-test/commitlog/CommitLog-2-1432760949933.log
2015-05-27 14:47:48.502 INFO 35270 --- [ main]
o.a.c.db.commitlog.CommitLogReplayer : Finished reading
build/cassandra-test/commitlog/CommitLog-2-1432760949933.log
2015-05-27 14:47:48.502 INFO 35270 --- [ main]
o.a.c.db.commitlog.CommitLogReplayer : Replaying
build/cassandra-test/commitlog/CommitLog-2-1432760949934.log
2015-05-27 14:47:48.502 INFO 35270 --- [ main]
o.a.c.db.commitlog.CommitLogReplayer : Finished reading
build/cassandra-test/commitlog/CommitLog-2-1432760949934.log
2015-05-27 14:47:48.503 INFO 35270 --- [ main]
o.a.c.db.commitlog.CommitLogReplayer : Replaying
build/cassandra-test/commitlog/CommitLog-2-1432760949935.log
2015-05-27 14:47:48.503 INFO 35270 --- [ main]
o.a.c.db.commitlog.CommitLogReplayer : Finished reading
build/cassandra-test/commitlog/CommitLog-2-1432760949935.log
2015-05-27 14:47:48.503 INFO 35270 --- [ main]
o.a.c.db.commitlog.CommitLogReplayer : Replaying
build/cassandra-test/commitlog/CommitLog-2-1432760949936.log
2015-05-27 14:47:48.504 INFO 35270 --- [ main]
o.a.c.db.commitlog.CommitLogReplayer : Finished reading
build/cassandra-test/commitlog/CommitLog-2-1432760949936.log
2015-05-27 14:47:48.504 INFO 35270 --- [ main]
o.a.c.db.commitlog.CommitLogReplayer : Replaying
build/cassandra-test/commitlog/CommitLog-2-1432760949937.log
2015-05-27 14:47:48.505 INFO 35270 --- [ main]
o.a.c.db.commitlog.CommitLogReplayer : Finished reading
build/cassandra-test/commitlog/CommitLog-2-1432760949937.log
2015-05-27 14:47:48.505 INFO 35270 --- [ main]
o.a.c.db.commitlog.CommitLogReplayer : Replaying
build/cassandra-test/commitlog/CommitLog-2-1432760949938.log
2015-05-27 14:47:48.505 INFO 35270 --- [ main]
o.a.c.db.commitlog.CommitLogReplayer : Finished reading
build/cassandra-test/commitlog/CommitLog-2-1432760949938.log
2015-05-27 14:47:48.505 INFO 35270 --- [ main]
o.a.c.db.commitlog.CommitLogReplayer : Replaying
build/cassandra-test/commitlog/CommitLog-2-1432760949939.log
2015-05-27 14:47:48.506 INFO 35270 --- [ main]
o.a.c.db.commitlog.CommitLogReplayer : Finished reading
build/cassandra-test/commitlog/CommitLog-2-1432760949939.log
2015-05-27 14:47:48.506 INFO 35270 --- [ main]
o.a.c.db.commitlog.CommitLogReplayer : Replaying
build/cassandra-test/commitlog/CommitLog-2-1432760949940.log
2015-05-27 14:47:48.507 INFO 35270 --- [ main]
o.a.c.db.commitlog.CommitLogReplayer : Finished reading
build/cassandra-test/commitlog/CommitLog-2-1432760949940.log
2015-05-27 14:47:48.507 INFO 35270 --- [ main]
o.a.c.db.commitlog.CommitLogReplayer : Replaying
build/cassandra-test/commitlog/CommitLog-2-1432760949941.log
2015-05-27 14:47:48.508 INFO 35270 --- [ main]
o.a.c.db.commitlog.CommitLogReplayer : Finished reading
build/cassandra-test/commitlog/CommitLog-2-1432760949941.log
2015-05-27 14:47:48.508 INFO 35270 --- [ main]
o.a.c.db.commitlog.CommitLogReplayer : Replaying
build/cassandra-test/commitlog/CommitLog-2-1432760949942.log
2015-05-27 14:47:48.508 INFO 35270 --- [ main]
o.a.c.db.commitlog.CommitLogReplayer : Finished reading
build/cassandra-test/commitlog/CommitLog-2-1432760949942.log
2015-05-27 14:47:48.508 INFO 35270 --- [ main]
o.a.c.db.commitlog.CommitLogReplayer : Replaying
build/cassandra-test/commitlog/CommitLog-2-1432760949943.log
2015-05-27 14:47:48.509 INFO 35270 --- [ main]
o.a.c.db.commitlog.CommitLogReplayer : Finished reading
build/cassandra-test/commitlog/CommitLog-2-1432760949943.log
2015-05-27 14:47:48.509 INFO 35270 --- [ main]
o.a.c.db.commitlog.CommitLogReplayer : Replaying
build/cassandra-test/commitlog/CommitLog-2-1432760949944.log
2015-05-27 14:47:48.510 INFO 35270 --- [ main]
o.a.c.db.commitlog.CommitLogReplayer : Finished reading
build/cassandra-test/commitlog/CommitLog-2-1432760949944.log
2015-05-27 14:47:48.510 INFO 35270 --- [ main]
o.a.c.db.commitlog.CommitLogReplayer : Replaying
build/cassandra-test/commitlog/CommitLog-2-1432760949945.log
2015-05-27 14:47:48.510 INFO 35270 --- [ main]
o.a.c.db.commitlog.CommitLogReplayer : Finished reading
build/cassandra-test/commitlog/CommitLog-2-1432760949945.log
2015-05-27 14:47:48.510 INFO 35270 --- [ main]
o.a.c.db.commitlog.CommitLogReplayer : Replaying
build/cassandra-test/commitlog/CommitLog-2-1432760949946.log
2015-05-27 14:47:48.511 INFO 35270 --- [ main]
o.a.c.db.commitlog.CommitLogReplayer : Finished reading
build/cassandra-test/commitlog/CommitLog-2-1432760949946.log
2015-05-27 14:47:48.511 INFO 35270 --- [ main]
o.a.c.db.commitlog.CommitLogReplayer : Replaying
build/cassandra-test/commitlog/CommitLog-2-1432760949947.log
2015-05-27 14:47:48.512 INFO 35270 --- [ main]
o.a.c.db.commitlog.CommitLogReplayer : Finished reading
build/cassandra-test/commitlog/CommitLog-2-1432760949947.log
2015-05-27 14:47:48.512 INFO 35270 --- [ main]
o.a.c.db.commitlog.CommitLogReplayer : Replaying
build/cassandra-test/commitlog/CommitLog-2-1432760949948.log
2015-05-27 14:47:48.513 INFO 35270 --- [ main]
o.a.c.db.commitlog.CommitLogReplayer : Finished reading
build/cassandra-test/commitlog/CommitLog-2-1432760949948.log
2015-05-27 14:47:48.513 INFO 35270 --- [ main]
o.a.c.db.commitlog.CommitLogReplayer : Replaying
build/cassandra-test/commitlog/CommitLog-2-1432760949949.log
2015-05-27 14:47:48.513 INFO 35270 --- [ main]
o.a.c.db.commitlog.CommitLogReplayer : Finished reading
build/cassandra-test/commitlog/CommitLog-2-1432760949949.log
2015-05-27 14:47:48.513 INFO 35270 --- [ main]
o.a.c.db.commitlog.CommitLogReplayer : Replaying
build/cassandra-test/commitlog/CommitLog-2-1432760949950.log
2015-05-27 14:47:48.514 INFO 35270 --- [ main]
o.a.c.db.commitlog.CommitLogReplayer : Finished reading
build/cassandra-test/commitlog/CommitLog-2-1432760949950.log
2015-05-27 14:47:48.516 INFO 35270 --- [ main]
o.apache.cassandra.db.ColumnFamilyStore : Enqueuing flush of
Memtable-schema_columnfamilies@1431213321(22187/221870 serialized/live bytes,
369 ops)
2015-05-27 14:47:48.518 INFO 35270 --- [ FlushWriter:1]
org.apache.cassandra.db.Memtable : Writing
Memtable-schema_columnfamilies@1431213321(22187/221870 serialized/live bytes,
369 ops)
2015-05-27 14:47:48.518 INFO 35270 --- [ main]
o.apache.cassandra.db.ColumnFamilyStore : Enqueuing flush of
Memtable-schema_keyspaces@1229381598(251/2510 serialized/live bytes, 8 ops)
2015-05-27 14:47:48.519 INFO 35270 --- [ main]
o.apache.cassandra.db.ColumnFamilyStore : Enqueuing flush of
Memtable-local@2006395236(52/520 serialized/live bytes, 2 ops)
2015-05-27 14:47:48.519 INFO 35270 --- [ main]
o.apache.cassandra.db.ColumnFamilyStore : Enqueuing flush of
Memtable-schema_columns@2035258234(23741/237410 serialized/live bytes, 386 ops)
2015-05-27 14:47:48.561 INFO 35270 --- [ FlushWriter:1]
org.apache.cassandra.db.Memtable : Completed flushing
build/cassandra-test/data/system/schema_columnfamilies/system-schema_columnfamilies-ic-49-Data.db
(4586 bytes) for commitlog position ReplayPosition(segmentId=1432763268394,
position=142)
2015-05-27 14:47:48.577 INFO 35270 --- [ FlushWriter:1]
org.apache.cassandra.db.Memtable : Writing
Memtable-schema_keyspaces@1229381598(251/2510 serialized/live bytes, 8 ops)
2015-05-27 14:47:48.585 INFO 35270 --- [ FlushWriter:1]
org.apache.cassandra.db.Memtable : Completed flushing
build/cassandra-test/data/system/schema_keyspaces/system-schema_keyspaces-ic-49-Data.db
(225 bytes) for commitlog position ReplayPosition(segmentId=1432763268394,
position=142)
2015-05-27 14:47:48.585 INFO 35270 --- [ FlushWriter:1]
org.apache.cassandra.db.Memtable : Writing
Memtable-local@2006395236(52/520 serialized/live bytes, 2 ops)
2015-05-27 14:47:48.591 INFO 35270 --- [ FlushWriter:1]
org.apache.cassandra.db.Memtable : Completed flushing
build/cassandra-test/data/system/local/system-local-ic-216-Data.db (84 bytes)
for commitlog position ReplayPosition(segmentId=1432763268394, position=142)
2015-05-27 14:47:48.591 INFO 35270 --- [ FlushWriter:1]
org.apache.cassandra.db.Memtable : Writing
Memtable-schema_columns@2035258234(23741/237410 serialized/live bytes, 386 ops)
2015-05-27 14:47:48.599 INFO 35270 --- [ FlushWriter:1]
org.apache.cassandra.db.Memtable : Completed flushing
build/cassandra-test/data/system/schema_columns/system-schema_columns-ic-49-Data.db
(4191 bytes) for commitlog position ReplayPosition(segmentId=1432763268394,
position=142)
2015-05-27 14:47:48.600 INFO 35270 --- [ main]
o.a.cassandra.db.commitlog.CommitLog : Log replay complete, 12 replayed
mutations
2015-05-27 14:47:48.685 INFO 35270 --- [ main]
o.a.cassandra.service.StorageService : Cassandra version: 1.2.13
2015-05-27 14:47:48.685 INFO 35270 --- [ main]
o.a.cassandra.service.StorageService : Thrift API version: 19.36.2
2015-05-27 14:47:48.685 INFO 35270 --- [ main]
o.a.cassandra.service.StorageService : CQL supported versions: 2.0.0,3.0.5
(default: 3.0.5)
2015-05-27 14:47:48.695 INFO 35270 --- [ main]
o.a.cassandra.service.StorageService : Loading persisted ring state
2015-05-27 14:47:48.703 INFO 35270 --- [ main]
o.a.cassandra.service.StorageService : Starting up server gossip
2015-05-27 14:47:48.712 INFO 35270 --- [ main]
o.apache.cassandra.db.ColumnFamilyStore : Enqueuing flush of
Memtable-local@307923638(251/2510 serialized/live bytes, 9 ops)
2015-05-27 14:47:48.712 INFO 35270 --- [ FlushWriter:1]
org.apache.cassandra.db.Memtable : Writing
Memtable-local@307923638(251/2510 serialized/live bytes, 9 ops)
2015-05-27 14:47:48.719 INFO 35270 --- [ FlushWriter:1]
org.apache.cassandra.db.Memtable : Completed flushing
build/cassandra-test/data/system/local/system-local-ic-217-Data.db (241 bytes)
for commitlog position ReplayPosition(segmentId=1432763268394, position=52889)
2015-05-27 14:47:48.733 INFO 35270 --- [ctionExecutor:1]
o.a.c.db.compaction.CompactionTask : Compacting
[SSTableReader(path='build/cassandra-test/data/system/local/system-local-ic-216-Data.db'),
SSTableReader(path='build/cassandra-test/data/system/local/system-local-ic-214-Data.db'),
SSTableReader(path='build/cassandra-test/data/system/local/system-local-ic-213-Data.db'),
SSTableReader(path='build/cassandra-test/data/system/local/system-local-ic-217-Data.db'),
SSTableReader(path='build/cassandra-test/data/system/local/system-local-ic-215-Data.db')]
2015-05-27 14:47:48.755 INFO 35270 --- [ main]
o.apache.cassandra.net.MessagingService : Starting Messaging Service on port
7000
2015-05-27 14:47:48.756 INFO 35270 --- [ctionExecutor:1]
o.a.c.db.compaction.CompactionTask : Compacted 5 sstables to
[build/cassandra-test/data/system/local/system-local-ic-218,]. 956 bytes to
421 (~44% of original) in 22ms = 0.018250MB/s. 5 total rows, 1 unique. Row
merge counts were {1:0, 2:0, 3:0, 4:0, 5:1, }
2015-05-27 14:47:48.768 INFO 35270 --- [ main]
o.a.cassandra.service.StorageService : Using saved token [0]
2015-05-27 14:47:48.769 INFO 35270 --- [ main]
o.apache.cassandra.db.ColumnFamilyStore : Enqueuing flush of
Memtable-local@1213461906(84/840 serialized/live bytes, 4 ops)
2015-05-27 14:47:48.769 INFO 35270 --- [ FlushWriter:1]
org.apache.cassandra.db.Memtable : Writing
Memtable-local@1213461906(84/840 serialized/live bytes, 4 ops)
2015-05-27 14:47:48.776 INFO 35270 --- [ FlushWriter:1]
org.apache.cassandra.db.Memtable : Completed flushing
build/cassandra-test/data/system/local/system-local-ic-219-Data.db (120 bytes)
for commitlog position ReplayPosition(segmentId=1432763268394, position=53164)
2015-05-27 14:47:48.781 INFO 35270 --- [ main]
o.apache.cassandra.db.ColumnFamilyStore : Enqueuing flush of
Memtable-local@699278615(32/320 serialized/live bytes, 2 ops)
2015-05-27 14:47:48.781 INFO 35270 --- [ FlushWriter:1]
org.apache.cassandra.db.Memtable : Writing
Memtable-local@699278615(32/320 serialized/live bytes, 2 ops)
2015-05-27 14:47:48.790 INFO 35270 --- [ FlushWriter:1]
org.apache.cassandra.db.Memtable : Completed flushing
build/cassandra-test/data/system/local/system-local-ic-220-Data.db (90 bytes)
for commitlog position ReplayPosition(segmentId=1432763268394, position=53320)
2015-05-27 14:47:48.804 INFO 35270 --- [ main]
o.a.cassandra.service.StorageService : Node /127.0.0.1 state jump to normal
2015-05-27 14:47:48.811 INFO 35270 --- [ main]
o.a.cassandra.service.StorageService : Startup completed! Now serving reads.
2015-05-27 14:47:48.822 INFO 35270 --- [ main]
c.n.astyanax.test.EmbeddedCassandra : Started cassandra deamon
2015-05-27 14:47:48.839 INFO 35270 --- [ddedCassandra-0]
org.apache.cassandra.transport.Server : Starting listening for CQL clients
on /127.0.0.1:9260...
2015-05-27 14:47:48.841 INFO 35270 --- [ddedCassandra-0]
o.apache.cassandra.thrift.ThriftServer : Binding thrift service to
/127.0.0.1:9160
2015-05-27 14:47:48.867 INFO 35270 --- [ddedCassandra-0]
o.apache.cassandra.thrift.ThriftServer : Using TFramedTransport with a max
frame size of 15728640 bytes.
2015-05-27 14:47:48.874 INFO 35270 --- [ddedCassandra-0]
o.a.c.thrift.TServerCustomFactory : Using synchronous/threadpool thrift
server on localhost : 9160
2015-05-27 14:47:48.875 INFO 35270 --- [ main]
tyanaxComponents$EmbeddedCassandraRunner : Waiting for Embedded Cassandra
instance...
2015-05-27 14:47:48.875 INFO 35270 --- [ Thread-3]
o.apache.cassandra.thrift.ThriftServer : Listening for thrift clients...
2015-05-27 14:47:48.876 INFO 35270 --- [ main]
tyanaxComponents$EmbeddedCassandraRunner : Embedded cassandra started.
[ERROR] [05/27/2015 14:47:59.990]
[default-akka.actor.default-dispatcher-26] [akka://default/user/$b] Futures
timed out after [1 second] java.util.concurrent.TimeoutException: Futures
timed out after [1 second] at
scala.concurrent.impl.Promise$DefaultPromise.ready(Promise.scala:219) at
scala.concurrent.impl.Promise$DefaultPromise.result(Promise.scala:223) at
scala.concurrent.Await$$anonfun$result$1.apply(package.scala:190) at
akka.dispatch.MonitorableThreadFactory$AkkaForkJoinWorkerThread$$anon$3.block(ThreadPoolBuilder.scala:169)
at
scala.concurrent.forkjoin.ForkJoinPool.managedBlock(ForkJoinPool.java:3640)
at
akka.dispatch.MonitorableThreadFactory$AkkaForkJoinWorkerThread.blockOn(ThreadPoolBuilder.scala:167)
at scala.concurrent.Await$.result(package.scala:190) at
com.xxx.actor.ClusterTestWrapperActor$$anonfun$receive$1.applyOrElse(ClusterTestWrapperActor.scala:40)
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) at
com.xxx.actor.ClusterTestWrapperActor.aroundReceive(ClusterTestWrapperActor.scala:30)
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) at
akka.actor.ActorCell.invoke(ActorCell.scala:487) at
akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) at
akka.dispatch.Mailbox.run(Mailbox.scala:221) 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)
--
>>>>>>>>>> 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.
