Created
December 4, 2018 23:19
-
-
Save aki-ks/e5ed97ab8fced784bfb7054ef47d99c9 to your computer and use it in GitHub Desktop.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| [info] Updating lagom-internal-meta-project-kafka... | |
| [info] Done updating. | |
| [info] Starting Kafka | |
| [info] Updating lagom-internal-meta-project-cassandra... | |
| [info] Done updating. | |
| .[info] Starting Cassandra | |
| ....................................................... | |
| [info] Cassandra server running at 127.0.0.1:4000 | |
| [info] Updating lagom-internal-meta-project-service-locator... | |
| [info] Done updating. | |
| [warn] Found version conflict(s) in library dependencies; some are suspected to be binary incompatible: | |
| [warn] * io.netty:netty-handler:4.1.29.Final is selected over 4.1.13.Final | |
| [warn] +- com.typesafe.netty:netty-reactive-streams:2.0.0 (depends on 4.1.13.Final) | |
| [warn] +- com.lightbend.lagom:lagom-client_2.12:1.4.9 (depends on 4.1.13.Final) | |
| [warn] * org.scala-lang.modules:scala-parser-combinators_2.12:1.1.0 is selected over {1.0.4, 1.0.6, 1.1.1} | |
| [warn] +- com.lightbend.lagom:lagom-logback_2.12:1.4.9 (depends on 1.1.1) | |
| [warn] +- com.lightbend.lagom:lagom-api_2.12:1.4.9 (depends on 1.0.4) | |
| [warn] +- com.typesafe.play:cachecontrol_2.12:1.1.3 (depends on 1.0.4) | |
| [warn] +- com.typesafe:ssl-config-core_2.12:0.3.6 (depends on 1.0.4) | |
| [warn] +- com.typesafe.play:play_2.12:2.6.20 () (depends on 1.0.4) | |
| [warn] * com.google.guava:guava:22.0 is selected over {16.0, 19.0, 20.0} | |
| [warn] +- com.lightbend.lagom:lagom-api_2.12:1.4.9 (depends on 22.0) | |
| [warn] +- com.typesafe.play:play_2.12:2.6.20 () (depends on 22.0) | |
| [warn] +- org.reflections:reflections:0.9.11 (depends on 20.0) | |
| [warn] +- com.google.inject:guice:4.1.0 (depends on 19.0) | |
| [warn] +- com.fasterxml.jackson.datatype:jackson-datatype-guava:2.8.11 (depends on 16.0) | |
| [warn] * com.typesafe.akka:akka-stream_2.12:2.5.18 is selected over {2.4.20, 2.5.9, 2.5.17} | |
| [warn] +- com.lightbend.lagom:lagom-logback_2.12:1.4.9 (depends on 2.5.18) | |
| [warn] +- com.lightbend.lagom:lagom-api_2.12:1.4.9 (depends on 2.5.18) | |
| [warn] +- com.typesafe.play:play-streams_2.12:2.6.20 () (depends on 2.5.17) | |
| [warn] +- com.typesafe.play:play-ws-standalone_2.12:1.1.10 (depends on 2.5.9) | |
| [warn] +- com.typesafe.akka:akka-http-core_2.12:10.0.14 () (depends on 2.4.20) | |
| [warn] * com.typesafe:ssl-config-core_2.12:0.3.6 is selected over 0.2.2 | |
| [warn] +- com.typesafe.akka:akka-stream_2.12:2.5.18 () (depends on 0.3.6) | |
| [warn] +- com.typesafe.play:play-ws-standalone_2.12:1.1.10 (depends on 0.2.2) | |
| [warn] * com.typesafe.akka:akka-actor_2.12:2.5.18 is selected over {2.4.20, 2.5.17} | |
| [warn] +- com.lightbend.lagom:lagom-logback_2.12:1.4.9 (depends on 2.5.18) | |
| [warn] +- com.typesafe.akka:akka-stream_2.12:2.5.18 () (depends on 2.5.18) | |
| [warn] +- com.lightbend.lagom:lagom-api_2.12:1.4.9 (depends on 2.5.18) | |
| [warn] +- com.typesafe.akka:akka-slf4j_2.12:2.5.18 () (depends on 2.5.18) | |
| [warn] +- com.typesafe.play:play_2.12:2.6.20 () (depends on 2.5.17) | |
| [warn] +- com.typesafe.akka:akka-parsing_2.12:10.0.14 () (depends on 2.4.20) | |
| [warn] Run 'evicted' to see detailed eviction warnings | |
| 2018-12-04T23:14:59.116Z [info] akka.event.slf4j.Slf4jLogger [] - Slf4jLogger started | |
| 2018-12-04T23:15:01.040Z [info] com.lightbend.lagom.discovery.ServiceLocatorServer [] - Service locator can be reached at http://localhost:9008 | |
| 2018-12-04T23:15:01.040Z [info] com.lightbend.lagom.discovery.ServiceLocatorServer [] - Service gateway can be reached at http://localhost:9000 | |
| [info] Service locator is running at http://localhost:9008 | |
| [info] Service gateway is running at http://localhost:9000 | |
| [info] Updating shapeless-json... | |
| [info] Done updating. | |
| [info] Updating auth-api... | |
| [info] Done updating. | |
| [warn] Found version conflict(s) in library dependencies; some are suspected to be binary incompatible: | |
| [warn] * org.scala-lang.modules:scala-parser-combinators_2.12:1.0.4 is selected over {1.0.6, 1.1.1} | |
| [warn] +- com.lightbend.lagom:lagom-api_2.12:1.4.9 (depends on 1.0.4) | |
| [warn] +- com.typesafe:ssl-config-core_2.12:0.3.6 (depends on 1.1.1) | |
| [warn] +- com.typesafe.play:play_2.12:2.6.20 () (depends on 1.0.6) | |
| [warn] Run 'evicted' to see detailed eviction warnings | |
| [info] Updating auth-impl... | |
| [info] Done updating. | |
| [warn] Found version conflict(s) in library dependencies; some are suspected to be binary incompatible: | |
| [warn] * com.github.jnr:jnr-constants:0.9.9 is selected over 0.9.0 | |
| [warn] +- org.lmdbjava:lmdbjava:0.6.1 (depends on 0.9.9) | |
| [warn] +- com.github.jnr:jnr-posix:3.0.27 (depends on 0.9.0) | |
| [warn] * io.netty:netty:3.10.6.Final is selected over 3.10.5.Final | |
| [warn] +- com.typesafe.akka:akka-remote_2.12:2.5.18 () (depends on 3.10.6.Final) | |
| [warn] +- org.apache.zookeeper:zookeeper:3.4.10 (depends on 3.10.5.Final) | |
| [warn] * io.netty:netty-handler:4.1.29.Final is selected over {4.0.44.Final, 4.1.13.Final} | |
| [warn] +- com.lightbend.lagom:lagom-persistence-cassandra-core_2.12:1.4.9 (depends on 4.1.29.Final) | |
| [warn] +- com.typesafe.netty:netty-reactive-streams:2.0.0 (depends on 4.1.13.Final) | |
| [warn] +- com.lightbend.lagom:lagom-client_2.12:1.4.9 (depends on 4.1.13.Final) | |
| [warn] +- com.datastax.cassandra:cassandra-driver-core:3.2.0 (depends on 4.0.44.Final) | |
| [warn] * org.scala-lang.modules:scala-parser-combinators_2.12:1.1.0 is selected over {1.0.4, 1.0.6, 1.1.1} | |
| [warn] +- com.typesafe.play:cachecontrol_2.12:1.1.3 (depends on 1.1.0) | |
| [warn] +- com.lightbend.lagom:lagom-cluster-core_2.12:1.4.9 (depends on 1.1.1) | |
| [warn] +- com.lightbend.lagom:lagom-logback_2.12:1.4.9 (depends on 1.0.4) | |
| [warn] +- org.apache.kafka:kafka_2.12:0.11.0.1 (depends on 1.0.4) | |
| [warn] +- com.lightbend.lagom:lagom-api_2.12:1.4.9 (depends on 1.0.4) | |
| [warn] +- com.typesafe:ssl-config-core_2.12:0.3.6 (depends on 1.0.4) | |
| [warn] +- com.typesafe.play:play_2.12:2.6.20 () (depends on 1.0.4) | |
| [warn] * com.google.guava:guava:22.0 is selected over {16.0.1, 19.0, 16.0} | |
| [warn] +- com.lightbend.lagom:lagom-scaladsl-cluster_2.12:1.4.9 (depends on 22.0) | |
| [warn] +- com.lightbend.lagom:lagom-api_2.12:1.4.9 (depends on 22.0) | |
| [warn] +- com.lightbend.lagom:lagom-scaladsl-play-json_2.12:1.4.9 (depends on 22.0) | |
| [warn] +- com.typesafe.play:play_2.12:2.6.20 () (depends on 22.0) | |
| [warn] +- com.fasterxml.jackson.datatype:jackson-datatype-guava:2.8.11 (depends on 16.0) | |
| [warn] +- com.datastax.cassandra:cassandra-driver-core:3.2.0 (depends on 19.0) | |
| [warn] +- org.apache.curator:curator-test:2.10.0 (depends on 16.0.1) | |
| [warn] +- org.apache.curator:curator-client:2.10.0 (depends on 16.0.1) | |
| [warn] * com.typesafe.akka:akka-stream_2.12:2.5.18 is selected over {2.5.7, 2.4.20, 2.5.9, 2.5.17} | |
| [warn] +- com.lightbend.lagom:lagom-logback_2.12:1.4.9 (depends on 2.5.18) | |
| [warn] +- com.lightbend.lagom:lagom-api_2.12:1.4.9 (depends on 2.5.18) | |
| [warn] +- com.typesafe.akka:akka-remote_2.12:2.5.18 () (depends on 2.5.18) | |
| [warn] +- com.typesafe.akka:akka-persistence-query_2.12:2.5.18 () (depends on 2.5.18) | |
| [warn] +- com.typesafe.play:play-streams_2.12:2.6.20 () (depends on 2.5.17) | |
| [warn] +- com.typesafe.play:play-ws-standalone_2.12:1.1.10 (depends on 2.5.9) | |
| [warn] +- com.typesafe.akka:akka-http-core_2.12:10.0.14 () (depends on 2.4.20) | |
| [warn] +- com.typesafe.akka:akka-stream-kafka_2.12:0.18 (depends on 2.5.7) | |
| [warn] * com.typesafe:ssl-config-core_2.12:0.3.6 is selected over 0.2.2 | |
| [warn] +- com.typesafe.akka:akka-stream_2.12:2.5.18 () (depends on 0.3.6) | |
| [warn] +- com.typesafe.play:play-ws-standalone_2.12:1.1.10 (depends on 0.2.2) | |
| [warn] * com.typesafe.akka:akka-actor_2.12:2.5.18 is selected over {2.4.20, 2.5.17} | |
| [warn] +- com.lightbend.lagom:lagom-logback_2.12:1.4.9 (depends on 2.5.18) | |
| [warn] +- com.typesafe.akka:akka-stream_2.12:2.5.18 () (depends on 2.5.18) | |
| [warn] +- com.typesafe.akka:akka-persistence_2.12:2.5.18 () (depends on 2.5.18) | |
| [warn] +- com.lightbend.lagom:lagom-api_2.12:1.4.9 (depends on 2.5.18) | |
| [warn] +- com.lightbend.lagom:lagom-scaladsl-play-json_2.12:1.4.9 (depends on 2.5.18) | |
| [warn] +- com.typesafe.akka:akka-slf4j_2.12:2.5.18 () (depends on 2.5.18) | |
| [warn] +- com.typesafe.akka:akka-remote_2.12:2.5.18 () (depends on 2.5.18) | |
| [warn] +- com.typesafe.akka:akka-testkit_2.12:2.5.18 () (depends on 2.5.18) | |
| [warn] +- com.typesafe.play:play_2.12:2.6.20 () (depends on 2.5.17) | |
| [warn] +- com.typesafe.akka:akka-parsing_2.12:10.0.14 () (depends on 2.4.20) | |
| [warn] Run 'evicted' to see detailed eviction warnings | |
| 00:15:07.653 [info] play.core.server.AkkaHttpServer [] - Listening for HTTP on /0:0:0:0:0:0:0:0:61221 | |
| [info] Compiling 3 Scala sources to /home/user/development/scala/lagom/file-heaven2/shapeless-json/target/scala-2.12/classes ... | |
| [info] Done compiling. | |
| [info] Compiling 1 Scala source to /home/user/development/scala/lagom/file-heaven2/auth-api/target/scala-2.12/classes ... | |
| [info] Done compiling. | |
| [info] Compiling 5 Scala sources to /home/user/development/scala/lagom/file-heaven2/auth-impl/target/scala-2.12/classes ... | |
| [info] Done compiling. | |
| 00:15:29.342 [info] akka.event.slf4j.Slf4jLogger [] - Slf4jLogger started | |
| 00:15:29.431 [info] akka.remote.Remoting [sourceThread=ForkJoinPool-9-worker-1, akkaSource=akka.remote.Remoting, sourceActorSystem=auth-impl-application, akkaTimestamp=23:15:29.399UTC] - Starting remoting | |
| 00:15:30.092 [info] akka.remote.Remoting [sourceThread=ForkJoinPool-9-worker-1, akkaSource=akka.remote.Remoting, sourceActorSystem=auth-impl-application, akkaTimestamp=23:15:30.091UTC] - Remoting started; listening on addresses :[akka.tcp://auth-impl-application@127.0.0.1:35917] | |
| 00:15:30.150 [info] akka.remote.Remoting [sourceThread=ForkJoinPool-9-worker-1, akkaTimestamp=23:15:30.117UTC, akkaSource=akka.remote.Remoting, sourceActorSystem=auth-impl-application] - Remoting now listens on addresses: [akka.tcp://auth-impl-application@127.0.0.1:35917] | |
| 00:15:30.150 [info] akka.cluster.Cluster(akka://auth-impl-application) [sourceThread=ForkJoinPool-9-worker-1, akkaTimestamp=23:15:30.150UTC, akkaSource=akka.cluster.Cluster(akka://auth-impl-application), sourceActorSystem=auth-impl-application] - Cluster Node [akka.tcp://auth-impl-application@127.0.0.1:35917] - Starting up, Akka version [2.5.18] ... | |
| 00:15:30.326 [info] akka.cluster.Cluster(akka://auth-impl-application) [sourceThread=ForkJoinPool-9-worker-1, akkaSource=akka.cluster.Cluster(akka://auth-impl-application), sourceActorSystem=auth-impl-application, akkaTimestamp=23:15:30.313UTC] - Cluster Node [akka.tcp://auth-impl-application@127.0.0.1:35917] - Registered cluster JMX MBean [akka:type=Cluster,port=35917] | |
| 00:15:30.326 [info] akka.cluster.Cluster(akka://auth-impl-application) [sourceThread=ForkJoinPool-9-worker-1, akkaTimestamp=23:15:30.313UTC, akkaSource=akka.cluster.Cluster(akka://auth-impl-application), sourceActorSystem=auth-impl-application] - Cluster Node [akka.tcp://auth-impl-application@127.0.0.1:35917] - Started up successfully | |
| 00:15:30.391 [info] akka.cluster.Cluster(akka://auth-impl-application) [sourceThread=auth-impl-application-akka.actor.default-dispatcher-4, akkaTimestamp=23:15:30.391UTC, akkaSource=akka.cluster.Cluster(akka://auth-impl-application), sourceActorSystem=auth-impl-application] - Cluster Node [akka.tcp://auth-impl-application@127.0.0.1:35917] - No seed-nodes configured, manual cluster join required | |
| 00:15:30.822 [info] akka.cluster.Cluster(akka://auth-impl-application) [sourceThread=auth-impl-application-akka.actor.default-dispatcher-7, akkaSource=akka.cluster.Cluster(akka://auth-impl-application), sourceActorSystem=auth-impl-application, akkaTimestamp=23:15:30.821UTC] - Cluster Node [akka.tcp://auth-impl-application@127.0.0.1:35917] - Node [akka.tcp://auth-impl-application@127.0.0.1:35917] is JOINING itself (with roles [dc-default]) and forming new cluster | |
| 00:15:30.824 [info] akka.cluster.Cluster(akka://auth-impl-application) [sourceThread=auth-impl-application-akka.actor.default-dispatcher-7, akkaTimestamp=23:15:30.823UTC, akkaSource=akka.cluster.Cluster(akka://auth-impl-application), sourceActorSystem=auth-impl-application] - Cluster Node [akka.tcp://auth-impl-application@127.0.0.1:35917] - Cluster Node [akka.tcp://auth-impl-application@127.0.0.1:35917] dc [default] is the new leader | |
| 00:15:30.863 [info] akka.cluster.Cluster(akka://auth-impl-application) [sourceThread=auth-impl-application-akka.actor.default-dispatcher-7, akkaTimestamp=23:15:30.863UTC, akkaSource=akka.cluster.Cluster(akka://auth-impl-application), sourceActorSystem=auth-impl-application] - Cluster Node [akka.tcp://auth-impl-application@127.0.0.1:35917] - Leader is moving node [akka.tcp://auth-impl-application@127.0.0.1:35917] to [Up] | |
| 00:15:32.249 [info] akka.cluster.singleton.ClusterSingletonManager [sourceThread=auth-impl-application-akka.actor.default-dispatcher-7, akkaTimestamp=23:15:32.249UTC, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/user/cassandraOffsetStorePrepare-singleton, sourceActorSystem=auth-impl-application] - Singleton manager starting singleton actor [akka://auth-impl-application/user/cassandraOffsetStorePrepare-singleton/singleton] | |
| 00:15:32.254 [info] akka.cluster.singleton.ClusterSingletonManager [sourceThread=auth-impl-application-akka.actor.default-dispatcher-7, akkaTimestamp=23:15:32.253UTC, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/user/cassandraOffsetStorePrepare-singleton, sourceActorSystem=auth-impl-application] - ClusterSingletonManager state change [Start -> Oldest] | |
| 00:15:32.258 [info] com.lightbend.lagom.internal.persistence.cluster.ClusterStartupTaskActor [sourceThread=auth-impl-application-akka.actor.default-dispatcher-3, akkaTimestamp=23:15:32.257UTC, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/user/cassandraOffsetStorePrepare-singleton/singleton/cassandraOffsetStorePrepare, sourceActorSystem=auth-impl-application] - Executing cluster start task cassandraOffsetStorePrepare. | |
| 00:15:32.347 [info] akka.cluster.singleton.ClusterSingletonManager [sourceThread=auth-impl-application-akka.actor.default-dispatcher-2, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/system/sharding/AuthEntityCoordinator, sourceActorSystem=auth-impl-application, akkaTimestamp=23:15:32.346UTC] - Singleton manager starting singleton actor [akka://auth-impl-application/system/sharding/AuthEntityCoordinator/singleton] | |
| 00:15:32.347 [info] akka.cluster.singleton.ClusterSingletonManager [sourceThread=auth-impl-application-akka.actor.default-dispatcher-2, akkaTimestamp=23:15:32.347UTC, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/system/sharding/AuthEntityCoordinator, sourceActorSystem=auth-impl-application] - ClusterSingletonManager state change [Start -> Oldest] | |
| 00:15:32.487 [info] akka.cluster.singleton.ClusterSingletonManager [sourceThread=auth-impl-application-akka.actor.default-dispatcher-6, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/system/sharding/kafkaProducer-token-topicCoordinator, sourceActorSystem=auth-impl-application, akkaTimestamp=23:15:32.487UTC] - Singleton manager starting singleton actor [akka://auth-impl-application/system/sharding/kafkaProducer-token-topicCoordinator/singleton] | |
| 00:15:32.487 [info] akka.cluster.singleton.ClusterSingletonManager [sourceThread=auth-impl-application-akka.actor.default-dispatcher-6, akkaTimestamp=23:15:32.487UTC, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/system/sharding/kafkaProducer-token-topicCoordinator, sourceActorSystem=auth-impl-application] - ClusterSingletonManager state change [Start -> Oldest] | |
| 00:15:32.591 [info] com.lightbend.lagom.internal.persistence.cluster.ClusterStartupTaskActor [sourceThread=auth-impl-application-akka.actor.default-dispatcher-18, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/user/readSideGlobalPrepare-UserIndexReadSideProcessor-singleton/singleton/readSideGlobalPrepare-UserIndexReadSideProcessor, sourceActorSystem=auth-impl-application, akkaTimestamp=23:15:32.591UTC] - Executing cluster start task readSideGlobalPrepare-UserIndexReadSideProcessor. | |
| 00:15:32.595 [info] akka.cluster.singleton.ClusterSingletonManager [sourceThread=auth-impl-application-akka.actor.default-dispatcher-2, akkaTimestamp=23:15:32.592UTC, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/user/readSideGlobalPrepare-UserIndexReadSideProcessor-singleton, sourceActorSystem=auth-impl-application] - Singleton manager starting singleton actor [akka://auth-impl-application/user/readSideGlobalPrepare-UserIndexReadSideProcessor-singleton/singleton] | |
| 00:15:32.597 [info] akka.cluster.singleton.ClusterSingletonManager [sourceThread=auth-impl-application-akka.actor.default-dispatcher-2, akkaTimestamp=23:15:32.597UTC, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/user/readSideGlobalPrepare-UserIndexReadSideProcessor-singleton, sourceActorSystem=auth-impl-application] - ClusterSingletonManager state change [Start -> Oldest] | |
| 00:15:32.738 [info] akka.cluster.singleton.ClusterSingletonManager [sourceThread=auth-impl-application-akka.actor.default-dispatcher-18, akkaTimestamp=23:15:32.738UTC, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/system/sharding/UserIndexReadSideProcessorCoordinator, sourceActorSystem=auth-impl-application] - Singleton manager starting singleton actor [akka://auth-impl-application/system/sharding/UserIndexReadSideProcessorCoordinator/singleton] | |
| 00:15:32.738 [info] akka.cluster.singleton.ClusterSingletonManager [sourceThread=auth-impl-application-akka.actor.default-dispatcher-18, akkaTimestamp=23:15:32.738UTC, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/system/sharding/UserIndexReadSideProcessorCoordinator, sourceActorSystem=auth-impl-application] - ClusterSingletonManager state change [Start -> Oldest] | |
| 00:15:33.086 [info] akka.cluster.singleton.ClusterSingletonProxy [sourceThread=auth-impl-application-akka.actor.default-dispatcher-4, akkaTimestamp=23:15:33.086UTC, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/user/cassandraOffsetStorePrepare-singletonProxy, sourceActorSystem=auth-impl-application] - Singleton identified at [akka://auth-impl-application/user/cassandraOffsetStorePrepare-singleton/singleton] | |
| 00:15:33.591 [info] akka.cluster.singleton.ClusterSingletonProxy [sourceThread=auth-impl-application-akka.actor.default-dispatcher-7, akkaTimestamp=23:15:33.590UTC, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/user/readSideGlobalPrepare-UserIndexReadSideProcessor-singletonProxy, sourceActorSystem=auth-impl-application] - Singleton identified at [akka://auth-impl-application/user/readSideGlobalPrepare-UserIndexReadSideProcessor-singleton/singleton] | |
| 00:15:34.167 [info] play.api.Play [] - Application started (Dev) | |
| [info] Service auth-impl listening for HTTP on 0:0:0:0:0:0:0:0:61221 | |
| [info] (Service started, press enter to stop and go back to the console...) | |
| 00:15:42.489 [warn] akka.cluster.sharding.ShardRegion [sourceThread=auth-impl-application-akka.actor.default-dispatcher-4, akkaTimestamp=23:15:42.483UTC, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/system/sharding/kafkaProducer-token-topic, sourceActorSystem=auth-impl-application] - Trying to register to coordinator at [ActorSelection[Anchor(akka://auth-impl-application/), Path(/system/sharding/kafkaProducer-token-topicCoordinator/singleton/coordinator)]], but no acknowledgement. Total [1] buffered messages. [Coordinator [Member(address = akka.tcp://auth-impl-application@127.0.0.1:35917, status = Up)] is reachable.] | |
| 00:15:42.681 [warn] akka.cluster.sharding.ShardRegion [sourceThread=auth-impl-application-akka.actor.default-dispatcher-7, akkaTimestamp=23:15:42.681UTC, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/system/sharding/UserIndexReadSideProcessor, sourceActorSystem=auth-impl-application] - Trying to register to coordinator at [ActorSelection[Anchor(akka://auth-impl-application/), Path(/system/sharding/UserIndexReadSideProcessorCoordinator/singleton/coordinator)]], but no acknowledgement. Total [20] buffered messages. [Coordinator [Member(address = akka.tcp://auth-impl-application@127.0.0.1:35917, status = Up)] is reachable.] | |
| 00:15:44.481 [warn] akka.cluster.sharding.ShardRegion [sourceThread=auth-impl-application-akka.actor.default-dispatcher-18, akkaTimestamp=23:15:44.481UTC, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/system/sharding/kafkaProducer-token-topic, sourceActorSystem=auth-impl-application] - Trying to register to coordinator at [ActorSelection[Anchor(akka://auth-impl-application/), Path(/system/sharding/kafkaProducer-token-topicCoordinator/singleton/coordinator)]], but no acknowledgement. Total [1] buffered messages. [Coordinator [Member(address = akka.tcp://auth-impl-application@127.0.0.1:35917, status = Up)] is reachable.] | |
| 00:15:44.681 [warn] akka.cluster.sharding.ShardRegion [sourceThread=auth-impl-application-akka.actor.default-dispatcher-2, akkaTimestamp=23:15:44.681UTC, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/system/sharding/UserIndexReadSideProcessor, sourceActorSystem=auth-impl-application] - Trying to register to coordinator at [ActorSelection[Anchor(akka://auth-impl-application/), Path(/system/sharding/UserIndexReadSideProcessorCoordinator/singleton/coordinator)]], but no acknowledgement. Total [20] buffered messages. [Coordinator [Member(address = akka.tcp://auth-impl-application@127.0.0.1:35917, status = Up)] is reachable.] | |
| 00:15:46.481 [warn] akka.cluster.sharding.ShardRegion [sourceThread=auth-impl-application-akka.actor.default-dispatcher-6, akkaTimestamp=23:15:46.481UTC, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/system/sharding/kafkaProducer-token-topic, sourceActorSystem=auth-impl-application] - Trying to register to coordinator at [ActorSelection[Anchor(akka://auth-impl-application/), Path(/system/sharding/kafkaProducer-token-topicCoordinator/singleton/coordinator)]], but no acknowledgement. Total [1] buffered messages. [Coordinator [Member(address = akka.tcp://auth-impl-application@127.0.0.1:35917, status = Up)] is reachable.] | |
| 00:15:46.681 [warn] akka.cluster.sharding.ShardRegion [sourceThread=auth-impl-application-akka.actor.default-dispatcher-6, akkaTimestamp=23:15:46.681UTC, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/system/sharding/UserIndexReadSideProcessor, sourceActorSystem=auth-impl-application] - Trying to register to coordinator at [ActorSelection[Anchor(akka://auth-impl-application/), Path(/system/sharding/UserIndexReadSideProcessorCoordinator/singleton/coordinator)]], but no acknowledgement. Total [20] buffered messages. [Coordinator [Member(address = akka.tcp://auth-impl-application@127.0.0.1:35917, status = Up)] is reachable.] | |
| 00:15:47.341 [info] com.lightbend.lagom.internal.persistence.cluster.ClusterStartupTaskActor [sourceThread=auth-impl-application-akka.actor.default-dispatcher-6, akkaTimestamp=23:15:47.341UTC, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/user/cassandraOffsetStorePrepare-singleton/singleton/cassandraOffsetStorePrepare, sourceActorSystem=auth-impl-application] - Cluster start task cassandraOffsetStorePrepare done. | |
| 00:15:48.481 [warn] akka.cluster.sharding.ShardRegion [sourceThread=auth-impl-application-akka.actor.default-dispatcher-4, akkaTimestamp=23:15:48.481UTC, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/system/sharding/kafkaProducer-token-topic, sourceActorSystem=auth-impl-application] - Trying to register to coordinator at [ActorSelection[Anchor(akka://auth-impl-application/), Path(/system/sharding/kafkaProducer-token-topicCoordinator/singleton/coordinator)]], but no acknowledgement. Total [1] buffered messages. [Coordinator [Member(address = akka.tcp://auth-impl-application@127.0.0.1:35917, status = Up)] is reachable.] | |
| 00:15:48.680 [warn] akka.cluster.sharding.ShardRegion [sourceThread=auth-impl-application-akka.actor.default-dispatcher-3, akkaTimestamp=23:15:48.680UTC, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/system/sharding/UserIndexReadSideProcessor, sourceActorSystem=auth-impl-application] - Trying to register to coordinator at [ActorSelection[Anchor(akka://auth-impl-application/), Path(/system/sharding/UserIndexReadSideProcessorCoordinator/singleton/coordinator)]], but no acknowledgement. Total [20] buffered messages. [Coordinator [Member(address = akka.tcp://auth-impl-application@127.0.0.1:35917, status = Up)] is reachable.] | |
| 12/05 00:15:49 ERROR[MigrationStage:1] o.a.c.s.CassandraDaemon - Exception in thread Thread[MigrationStage:1,5,main] | |
| org.apache.cassandra.exceptions.ConfigurationException: Column family ID mismatch (found 8347f790-f81a-11e8-a523-0d377e2d0447; expected 83427950-f81a-11e8-a523-0d377e2d0447) | |
| at org.apache.cassandra.config.CFMetaData.validateCompatibility(CFMetaData.java:941) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.config.CFMetaData.apply(CFMetaData.java:895) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.config.Schema.updateTable(Schema.java:687) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.schema.SchemaKeyspace.updateKeyspace(SchemaKeyspace.java:1464) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.schema.SchemaKeyspace.mergeSchema(SchemaKeyspace.java:1420) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.schema.SchemaKeyspace.mergeSchema(SchemaKeyspace.java:1389) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.schema.SchemaKeyspace.mergeSchemaAndAnnounceVersion(SchemaKeyspace.java:1366) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.service.MigrationManager$1.runMayThrow(MigrationManager.java:588) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.utils.WrappedRunnable.run(WrappedRunnable.java:28) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) ~[na:1.8.0_192] | |
| at java.util.concurrent.FutureTask.run(FutureTask.java:266) ~[na:1.8.0_192] | |
| at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[na:1.8.0_192] | |
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [na:1.8.0_192] | |
| at org.apache.cassandra.concurrent.NamedThreadFactory.lambda$threadLocalDeallocator$0(NamedThreadFactory.java:81) [cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at java.lang.Thread.run(Thread.java:748) ~[na:1.8.0_192] | |
| 12/05 00:15:49 ERROR[Native-Transport-Requests-4] o.a.c.t.Message - Unexpected error during query | |
| java.lang.RuntimeException: java.util.concurrent.ExecutionException: org.apache.cassandra.exceptions.ConfigurationException: Column family ID mismatch (found 8347f790-f81a-11e8-a523-0d377e2d0447; expected 83427950-f81a-11e8-a523-0d377e2d0447) | |
| at org.apache.cassandra.utils.FBUtilities.waitOnFuture(FBUtilities.java:385) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.service.MigrationManager.announce(MigrationManager.java:570) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.service.MigrationManager.announceNewColumnFamily(MigrationManager.java:377) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.service.MigrationManager.announceNewColumnFamily(MigrationManager.java:362) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.service.MigrationManager.announceNewColumnFamily(MigrationManager.java:342) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.cql3.statements.CreateTableStatement.announceMigration(CreateTableStatement.java:89) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.cql3.statements.SchemaAlteringStatement.execute(SchemaAlteringStatement.java:123) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.cql3.QueryProcessor.processStatement(QueryProcessor.java:224) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.cql3.QueryProcessor.process(QueryProcessor.java:255) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.cql3.QueryProcessor.process(QueryProcessor.java:240) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.transport.messages.QueryMessage.execute(QueryMessage.java:116) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.transport.Message$Dispatcher.channelRead0(Message.java:517) [cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.transport.Message$Dispatcher.channelRead0(Message.java:410) [cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105) [cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:357) [cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at io.netty.channel.AbstractChannelHandlerContext.access$600(AbstractChannelHandlerContext.java:35) [cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at io.netty.channel.AbstractChannelHandlerContext$7.run(AbstractChannelHandlerContext.java:348) [cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [na:1.8.0_192] | |
| at org.apache.cassandra.concurrent.AbstractLocalAwareExecutorService$FutureTask.run(AbstractLocalAwareExecutorService.java:162) [cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.concurrent.SEPWorker.run(SEPWorker.java:109) [cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at java.lang.Thread.run(Thread.java:748) [na:1.8.0_192] | |
| Caused by: java.util.concurrent.ExecutionException: org.apache.cassandra.exceptions.ConfigurationException: Column family ID mismatch (found 8347f790-f81a-11e8-a523-0d377e2d0447; expected 83427950-f81a-11e8-a523-0d377e2d0447) | |
| at java.util.concurrent.FutureTask.report(FutureTask.java:122) ~[na:1.8.0_192] | |
| at java.util.concurrent.FutureTask.get(FutureTask.java:192) ~[na:1.8.0_192] | |
| at org.apache.cassandra.utils.FBUtilities.waitOnFuture(FBUtilities.java:381) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| ... 20 common frames omitted | |
| Caused by: org.apache.cassandra.exceptions.ConfigurationException: Column family ID mismatch (found 8347f790-f81a-11e8-a523-0d377e2d0447; expected 83427950-f81a-11e8-a523-0d377e2d0447) | |
| at org.apache.cassandra.config.CFMetaData.validateCompatibility(CFMetaData.java:941) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.config.CFMetaData.apply(CFMetaData.java:895) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.config.Schema.updateTable(Schema.java:687) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.schema.SchemaKeyspace.updateKeyspace(SchemaKeyspace.java:1464) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.schema.SchemaKeyspace.mergeSchema(SchemaKeyspace.java:1420) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.schema.SchemaKeyspace.mergeSchema(SchemaKeyspace.java:1389) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.schema.SchemaKeyspace.mergeSchemaAndAnnounceVersion(SchemaKeyspace.java:1366) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.service.MigrationManager$1.runMayThrow(MigrationManager.java:588) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.utils.WrappedRunnable.run(WrappedRunnable.java:28) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [na:1.8.0_192] | |
| at java.util.concurrent.FutureTask.run(FutureTask.java:266) ~[na:1.8.0_192] | |
| at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[na:1.8.0_192] | |
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[na:1.8.0_192] | |
| at org.apache.cassandra.concurrent.NamedThreadFactory.lambda$threadLocalDeallocator$0(NamedThreadFactory.java:81) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| ... 1 common frames omitted | |
| 12/05 00:15:49 ERROR[Native-Transport-Requests-4] o.a.c.t.m.ErrorMessage - Unexpected exception during request | |
| java.lang.RuntimeException: java.util.concurrent.ExecutionException: org.apache.cassandra.exceptions.ConfigurationException: Column family ID mismatch (found 8347f790-f81a-11e8-a523-0d377e2d0447; expected 83427950-f81a-11e8-a523-0d377e2d0447) | |
| at org.apache.cassandra.utils.FBUtilities.waitOnFuture(FBUtilities.java:385) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.service.MigrationManager.announce(MigrationManager.java:570) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.service.MigrationManager.announceNewColumnFamily(MigrationManager.java:377) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.service.MigrationManager.announceNewColumnFamily(MigrationManager.java:362) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.service.MigrationManager.announceNewColumnFamily(MigrationManager.java:342) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.cql3.statements.CreateTableStatement.announceMigration(CreateTableStatement.java:89) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.cql3.statements.SchemaAlteringStatement.execute(SchemaAlteringStatement.java:123) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.cql3.QueryProcessor.processStatement(QueryProcessor.java:224) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.cql3.QueryProcessor.process(QueryProcessor.java:255) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.cql3.QueryProcessor.process(QueryProcessor.java:240) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.transport.messages.QueryMessage.execute(QueryMessage.java:116) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.transport.Message$Dispatcher.channelRead0(Message.java:517) [cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.transport.Message$Dispatcher.channelRead0(Message.java:410) [cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105) [cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:357) [cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at io.netty.channel.AbstractChannelHandlerContext.access$600(AbstractChannelHandlerContext.java:35) [cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at io.netty.channel.AbstractChannelHandlerContext$7.run(AbstractChannelHandlerContext.java:348) [cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [na:1.8.0_192] | |
| at org.apache.cassandra.concurrent.AbstractLocalAwareExecutorService$FutureTask.run(AbstractLocalAwareExecutorService.java:162) [cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.concurrent.SEPWorker.run(SEPWorker.java:109) [cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at java.lang.Thread.run(Thread.java:748) [na:1.8.0_192] | |
| Caused by: java.util.concurrent.ExecutionException: org.apache.cassandra.exceptions.ConfigurationException: Column family ID mismatch (found 8347f790-f81a-11e8-a523-0d377e2d0447; expected 83427950-f81a-11e8-a523-0d377e2d0447) | |
| at java.util.concurrent.FutureTask.report(FutureTask.java:122) ~[na:1.8.0_192] | |
| at java.util.concurrent.FutureTask.get(FutureTask.java:192) ~[na:1.8.0_192] | |
| at org.apache.cassandra.utils.FBUtilities.waitOnFuture(FBUtilities.java:381) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| ... 20 common frames omitted | |
| Caused by: org.apache.cassandra.exceptions.ConfigurationException: Column family ID mismatch (found 8347f790-f81a-11e8-a523-0d377e2d0447; expected 83427950-f81a-11e8-a523-0d377e2d0447) | |
| at org.apache.cassandra.config.CFMetaData.validateCompatibility(CFMetaData.java:941) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.config.CFMetaData.apply(CFMetaData.java:895) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.config.Schema.updateTable(Schema.java:687) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.schema.SchemaKeyspace.updateKeyspace(SchemaKeyspace.java:1464) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.schema.SchemaKeyspace.mergeSchema(SchemaKeyspace.java:1420) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.schema.SchemaKeyspace.mergeSchema(SchemaKeyspace.java:1389) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.schema.SchemaKeyspace.mergeSchemaAndAnnounceVersion(SchemaKeyspace.java:1366) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.service.MigrationManager$1.runMayThrow(MigrationManager.java:588) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.utils.WrappedRunnable.run(WrappedRunnable.java:28) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [na:1.8.0_192] | |
| at java.util.concurrent.FutureTask.run(FutureTask.java:266) ~[na:1.8.0_192] | |
| at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[na:1.8.0_192] | |
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[na:1.8.0_192] | |
| at org.apache.cassandra.concurrent.NamedThreadFactory.lambda$threadLocalDeallocator$0(NamedThreadFactory.java:81) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| ... 1 common frames omitted | |
| 00:15:49.948 [error] akka.actor.OneForOneStrategy [sourceThread=auth-impl-application-akka.actor.default-dispatcher-6, akkaTimestamp=23:15:49.933UTC, akkaSource=akka://auth-impl-application/user/readSideGlobalPrepare-UserIndexReadSideProcessor-singleton/singleton/readSideGlobalPrepare-UserIndexReadSideProcessor, sourceActorSystem=auth-impl-application] - com.datastax.driver.core.exceptions.TransportException: [/127.0.0.1:4000] Connection has been closed | |
| java.util.concurrent.ExecutionException: com.datastax.driver.core.exceptions.TransportException: [/127.0.0.1:4000] Connection has been closed | |
| at com.google.common.util.concurrent.AbstractFuture.getDoneValue(AbstractFuture.java:503) | |
| at com.google.common.util.concurrent.AbstractFuture.get(AbstractFuture.java:462) | |
| at akka.persistence.cassandra.package$ListenableFutureConverter$$anon$2.$anonfun$run$2(package.scala:25) | |
| at scala.util.Try$.apply(Try.scala:209) | |
| at akka.persistence.cassandra.package$ListenableFutureConverter$$anon$2.run(package.scala:25) | |
| at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:40) | |
| at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) | |
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) | |
| at java.lang.Thread.run(Thread.java:748) | |
| Caused by: com.datastax.driver.core.exceptions.TransportException: [/127.0.0.1:4000] Connection has been closed | |
| at com.datastax.driver.core.Connection$ConnectionCloseFuture.force(Connection.java:1215) | |
| at com.datastax.driver.core.Connection$ConnectionCloseFuture.force(Connection.java:1200) | |
| at com.datastax.driver.core.Connection.defunct(Connection.java:450) | |
| at com.datastax.driver.core.RequestHandler$SpeculativeExecution.onSet(RequestHandler.java:579) | |
| at com.datastax.driver.core.Connection$Dispatcher.channelRead0(Connection.java:1075) | |
| at com.datastax.driver.core.Connection$Dispatcher.channelRead0(Connection.java:998) | |
| at io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105) | |
| at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) | |
| at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) | |
| at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340) | |
| at io.netty.handler.timeout.IdleStateHandler.channelRead(IdleStateHandler.java:286) | |
| at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) | |
| at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) | |
| at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340) | |
| at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:102) | |
| at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) | |
| at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) | |
| at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340) | |
| at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:310) | |
| at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:284) | |
| at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) | |
| at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) | |
| at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340) | |
| at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1434) | |
| at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) | |
| at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) | |
| at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:965) | |
| at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:163) | |
| at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:628) | |
| at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:563) | |
| at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:480) | |
| at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:442) | |
| at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:884) | |
| at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) | |
| ... 1 common frames omitted | |
| 00:15:50.491 [warn] akka.cluster.sharding.ShardRegion [sourceThread=auth-impl-application-akka.actor.default-dispatcher-4, akkaTimestamp=23:15:50.490UTC, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/system/sharding/kafkaProducer-token-topic, sourceActorSystem=auth-impl-application] - Trying to register to coordinator at [ActorSelection[Anchor(akka://auth-impl-application/), Path(/system/sharding/kafkaProducer-token-topicCoordinator/singleton/coordinator)]], but no acknowledgement. Total [1] buffered messages. [Coordinator [Member(address = akka.tcp://auth-impl-application@127.0.0.1:35917, status = Up)] is reachable.] | |
| 00:15:50.681 [warn] akka.cluster.sharding.ShardRegion [sourceThread=auth-impl-application-akka.actor.default-dispatcher-2, akkaTimestamp=23:15:50.681UTC, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/system/sharding/UserIndexReadSideProcessor, sourceActorSystem=auth-impl-application] - Trying to register to coordinator at [ActorSelection[Anchor(akka://auth-impl-application/), Path(/system/sharding/UserIndexReadSideProcessorCoordinator/singleton/coordinator)]], but no acknowledgement. Total [20] buffered messages. [Coordinator [Member(address = akka.tcp://auth-impl-application@127.0.0.1:35917, status = Up)] is reachable.] | |
| 12/05 00:15:51 ERROR[MigrationStage:1] o.a.c.s.CassandraDaemon - Exception in thread Thread[MigrationStage:1,5,main] | |
| org.apache.cassandra.exceptions.ConfigurationException: Column family ID mismatch (found 8347f790-f81a-11e8-a523-0d377e2d0447; expected 83427950-f81a-11e8-a523-0d377e2d0447) | |
| at org.apache.cassandra.config.CFMetaData.validateCompatibility(CFMetaData.java:941) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.config.CFMetaData.apply(CFMetaData.java:895) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.config.Schema.updateTable(Schema.java:687) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.schema.SchemaKeyspace.updateKeyspace(SchemaKeyspace.java:1464) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.schema.SchemaKeyspace.mergeSchema(SchemaKeyspace.java:1420) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.schema.SchemaKeyspace.mergeSchema(SchemaKeyspace.java:1389) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.schema.SchemaKeyspace.mergeSchemaAndAnnounceVersion(SchemaKeyspace.java:1366) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.service.MigrationManager$1.runMayThrow(MigrationManager.java:588) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.utils.WrappedRunnable.run(WrappedRunnable.java:28) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) ~[na:1.8.0_192] | |
| at java.util.concurrent.FutureTask.run(FutureTask.java:266) ~[na:1.8.0_192] | |
| at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[na:1.8.0_192] | |
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [na:1.8.0_192] | |
| at org.apache.cassandra.concurrent.NamedThreadFactory.lambda$threadLocalDeallocator$0(NamedThreadFactory.java:81) [cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at java.lang.Thread.run(Thread.java:748) ~[na:1.8.0_192] | |
| 12/05 00:15:52 ERROR[Native-Transport-Requests-10] o.a.c.t.Message - Unexpected error during query | |
| java.lang.RuntimeException: java.util.concurrent.ExecutionException: org.apache.cassandra.exceptions.ConfigurationException: Column family ID mismatch (found 8347f790-f81a-11e8-a523-0d377e2d0447; expected 83427950-f81a-11e8-a523-0d377e2d0447) | |
| at org.apache.cassandra.utils.FBUtilities.waitOnFuture(FBUtilities.java:385) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.service.MigrationManager.announce(MigrationManager.java:570) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.service.MigrationManager.announceNewColumnFamily(MigrationManager.java:377) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.service.MigrationManager.announceNewColumnFamily(MigrationManager.java:362) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.service.MigrationManager.announceNewColumnFamily(MigrationManager.java:342) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.cql3.statements.CreateTableStatement.announceMigration(CreateTableStatement.java:89) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.cql3.statements.SchemaAlteringStatement.execute(SchemaAlteringStatement.java:123) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.cql3.QueryProcessor.processStatement(QueryProcessor.java:224) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.cql3.QueryProcessor.process(QueryProcessor.java:255) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.cql3.QueryProcessor.process(QueryProcessor.java:240) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.transport.messages.QueryMessage.execute(QueryMessage.java:116) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.transport.Message$Dispatcher.channelRead0(Message.java:517) [cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.transport.Message$Dispatcher.channelRead0(Message.java:410) [cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105) [cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:357) [cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at io.netty.channel.AbstractChannelHandlerContext.access$600(AbstractChannelHandlerContext.java:35) [cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at io.netty.channel.AbstractChannelHandlerContext$7.run(AbstractChannelHandlerContext.java:348) [cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [na:1.8.0_192] | |
| at org.apache.cassandra.concurrent.AbstractLocalAwareExecutorService$FutureTask.run(AbstractLocalAwareExecutorService.java:162) [cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.concurrent.SEPWorker.run(SEPWorker.java:109) [cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at java.lang.Thread.run(Thread.java:748) [na:1.8.0_192] | |
| Caused by: java.util.concurrent.ExecutionException: org.apache.cassandra.exceptions.ConfigurationException: Column family ID mismatch (found 8347f790-f81a-11e8-a523-0d377e2d0447; expected 83427950-f81a-11e8-a523-0d377e2d0447) | |
| at java.util.concurrent.FutureTask.report(FutureTask.java:122) ~[na:1.8.0_192] | |
| at java.util.concurrent.FutureTask.get(FutureTask.java:192) ~[na:1.8.0_192] | |
| at org.apache.cassandra.utils.FBUtilities.waitOnFuture(FBUtilities.java:381) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| ... 20 common frames omitted | |
| Caused by: org.apache.cassandra.exceptions.ConfigurationException: Column family ID mismatch (found 8347f790-f81a-11e8-a523-0d377e2d0447; expected 83427950-f81a-11e8-a523-0d377e2d0447) | |
| at org.apache.cassandra.config.CFMetaData.validateCompatibility(CFMetaData.java:941) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.config.CFMetaData.apply(CFMetaData.java:895) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.config.Schema.updateTable(Schema.java:687) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.schema.SchemaKeyspace.updateKeyspace(SchemaKeyspace.java:1464) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.schema.SchemaKeyspace.mergeSchema(SchemaKeyspace.java:1420) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.schema.SchemaKeyspace.mergeSchema(SchemaKeyspace.java:1389) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.schema.SchemaKeyspace.mergeSchemaAndAnnounceVersion(SchemaKeyspace.java:1366) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.service.MigrationManager$1.runMayThrow(MigrationManager.java:588) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.utils.WrappedRunnable.run(WrappedRunnable.java:28) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [na:1.8.0_192] | |
| at java.util.concurrent.FutureTask.run(FutureTask.java:266) ~[na:1.8.0_192] | |
| at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[na:1.8.0_192] | |
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[na:1.8.0_192] | |
| at org.apache.cassandra.concurrent.NamedThreadFactory.lambda$threadLocalDeallocator$0(NamedThreadFactory.java:81) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| ... 1 common frames omitted | |
| 12/05 00:15:52 ERROR[Native-Transport-Requests-10] o.a.c.t.m.ErrorMessage - Unexpected exception during request | |
| java.lang.RuntimeException: java.util.concurrent.ExecutionException: org.apache.cassandra.exceptions.ConfigurationException: Column family ID mismatch (found 8347f790-f81a-11e8-a523-0d377e2d0447; expected 83427950-f81a-11e8-a523-0d377e2d0447) | |
| at org.apache.cassandra.utils.FBUtilities.waitOnFuture(FBUtilities.java:385) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.service.MigrationManager.announce(MigrationManager.java:570) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.service.MigrationManager.announceNewColumnFamily(MigrationManager.java:377) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.service.MigrationManager.announceNewColumnFamily(MigrationManager.java:362) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.service.MigrationManager.announceNewColumnFamily(MigrationManager.java:342) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.cql3.statements.CreateTableStatement.announceMigration(CreateTableStatement.java:89) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.cql3.statements.SchemaAlteringStatement.execute(SchemaAlteringStatement.java:123) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.cql3.QueryProcessor.processStatement(QueryProcessor.java:224) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.cql3.QueryProcessor.process(QueryProcessor.java:255) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.cql3.QueryProcessor.process(QueryProcessor.java:240) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.transport.messages.QueryMessage.execute(QueryMessage.java:116) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.transport.Message$Dispatcher.channelRead0(Message.java:517) [cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.transport.Message$Dispatcher.channelRead0(Message.java:410) [cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105) [cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:357) [cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at io.netty.channel.AbstractChannelHandlerContext.access$600(AbstractChannelHandlerContext.java:35) [cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at io.netty.channel.AbstractChannelHandlerContext$7.run(AbstractChannelHandlerContext.java:348) [cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [na:1.8.0_192] | |
| at org.apache.cassandra.concurrent.AbstractLocalAwareExecutorService$FutureTask.run(AbstractLocalAwareExecutorService.java:162) [cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.concurrent.SEPWorker.run(SEPWorker.java:109) [cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at java.lang.Thread.run(Thread.java:748) [na:1.8.0_192] | |
| Caused by: java.util.concurrent.ExecutionException: org.apache.cassandra.exceptions.ConfigurationException: Column family ID mismatch (found 8347f790-f81a-11e8-a523-0d377e2d0447; expected 83427950-f81a-11e8-a523-0d377e2d0447) | |
| at java.util.concurrent.FutureTask.report(FutureTask.java:122) ~[na:1.8.0_192] | |
| at java.util.concurrent.FutureTask.get(FutureTask.java:192) ~[na:1.8.0_192] | |
| at org.apache.cassandra.utils.FBUtilities.waitOnFuture(FBUtilities.java:381) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| ... 20 common frames omitted | |
| Caused by: org.apache.cassandra.exceptions.ConfigurationException: Column family ID mismatch (found 8347f790-f81a-11e8-a523-0d377e2d0447; expected 83427950-f81a-11e8-a523-0d377e2d0447) | |
| at org.apache.cassandra.config.CFMetaData.validateCompatibility(CFMetaData.java:941) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.config.CFMetaData.apply(CFMetaData.java:895) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.config.Schema.updateTable(Schema.java:687) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.schema.SchemaKeyspace.updateKeyspace(SchemaKeyspace.java:1464) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.schema.SchemaKeyspace.mergeSchema(SchemaKeyspace.java:1420) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.schema.SchemaKeyspace.mergeSchema(SchemaKeyspace.java:1389) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.schema.SchemaKeyspace.mergeSchemaAndAnnounceVersion(SchemaKeyspace.java:1366) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.service.MigrationManager$1.runMayThrow(MigrationManager.java:588) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at org.apache.cassandra.utils.WrappedRunnable.run(WrappedRunnable.java:28) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [na:1.8.0_192] | |
| at java.util.concurrent.FutureTask.run(FutureTask.java:266) ~[na:1.8.0_192] | |
| at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[na:1.8.0_192] | |
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[na:1.8.0_192] | |
| at org.apache.cassandra.concurrent.NamedThreadFactory.lambda$threadLocalDeallocator$0(NamedThreadFactory.java:81) ~[cassandra-bundle.jar:0.59-SNAPSHOT] | |
| ... 1 common frames omitted | |
| 00:15:52.094 [error] akka.cluster.sharding.PersistentShardCoordinator [sourceThread=auth-impl-application-akka.actor.default-dispatcher-17, akkaTimestamp=23:15:52.064UTC, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/system/sharding/AuthEntityCoordinator/singleton/coordinator, sourceActorSystem=auth-impl-application] - Persistence failure when replaying events for persistenceId [/sharding/AuthEntityCoordinator]. Last known sequence number [0] | |
| java.util.concurrent.ExecutionException: com.datastax.driver.core.exceptions.ServerError: An unexpected error occurred server side on /127.0.0.1:4000: java.lang.RuntimeException: java.util.concurrent.ExecutionException: org.apache.cassandra.exceptions.ConfigurationException: Column family ID mismatch (found 8347f790-f81a-11e8-a523-0d377e2d0447; expected 83427950-f81a-11e8-a523-0d377e2d0447) | |
| at com.google.common.util.concurrent.AbstractFuture.getDoneValue(AbstractFuture.java:503) | |
| at com.google.common.util.concurrent.AbstractFuture.get(AbstractFuture.java:462) | |
| at akka.persistence.cassandra.package$$anon$1.$anonfun$run$1(package.scala:18) | |
| at scala.util.Try$.apply(Try.scala:209) | |
| at akka.persistence.cassandra.package$$anon$1.run(package.scala:18) | |
| at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:40) | |
| at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) | |
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) | |
| at java.lang.Thread.run(Thread.java:748) | |
| Caused by: com.datastax.driver.core.exceptions.ServerError: An unexpected error occurred server side on /127.0.0.1:4000: java.lang.RuntimeException: java.util.concurrent.ExecutionException: org.apache.cassandra.exceptions.ConfigurationException: Column family ID mismatch (found 8347f790-f81a-11e8-a523-0d377e2d0447; expected 83427950-f81a-11e8-a523-0d377e2d0447) | |
| at com.datastax.driver.core.Responses$Error.asException(Responses.java:120) | |
| at com.datastax.driver.core.RequestHandler$SpeculativeExecution.onSet(RequestHandler.java:507) | |
| at com.datastax.driver.core.Connection$Dispatcher.channelRead0(Connection.java:1075) | |
| at com.datastax.driver.core.Connection$Dispatcher.channelRead0(Connection.java:998) | |
| at io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105) | |
| at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) | |
| at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) | |
| at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340) | |
| at io.netty.handler.timeout.IdleStateHandler.channelRead(IdleStateHandler.java:286) | |
| at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) | |
| at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) | |
| at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340) | |
| at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:102) | |
| at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) | |
| at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) | |
| at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340) | |
| at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:310) | |
| at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:284) | |
| at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) | |
| at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) | |
| at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340) | |
| at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1434) | |
| at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) | |
| at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) | |
| at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:965) | |
| at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:163) | |
| at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:628) | |
| at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:563) | |
| at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:480) | |
| at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:442) | |
| at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:884) | |
| at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) | |
| ... 1 common frames omitted | |
| 00:15:52.094 [error] akka.cluster.sharding.PersistentShardCoordinator [sourceThread=auth-impl-application-akka.actor.default-dispatcher-3, akkaTimestamp=23:15:52.066UTC, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/system/sharding/UserIndexReadSideProcessorCoordinator/singleton/coordinator, sourceActorSystem=auth-impl-application] - Persistence failure when replaying events for persistenceId [/sharding/UserIndexReadSideProcessorCoordinator]. Last known sequence number [0] | |
| java.util.concurrent.ExecutionException: com.datastax.driver.core.exceptions.ServerError: An unexpected error occurred server side on /127.0.0.1:4000: java.lang.RuntimeException: java.util.concurrent.ExecutionException: org.apache.cassandra.exceptions.ConfigurationException: Column family ID mismatch (found 8347f790-f81a-11e8-a523-0d377e2d0447; expected 83427950-f81a-11e8-a523-0d377e2d0447) | |
| at com.google.common.util.concurrent.AbstractFuture.getDoneValue(AbstractFuture.java:503) | |
| at com.google.common.util.concurrent.AbstractFuture.get(AbstractFuture.java:462) | |
| at akka.persistence.cassandra.package$$anon$1.$anonfun$run$1(package.scala:18) | |
| at scala.util.Try$.apply(Try.scala:209) | |
| at akka.persistence.cassandra.package$$anon$1.run(package.scala:18) | |
| at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:40) | |
| at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) | |
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) | |
| at java.lang.Thread.run(Thread.java:748) | |
| Caused by: com.datastax.driver.core.exceptions.ServerError: An unexpected error occurred server side on /127.0.0.1:4000: java.lang.RuntimeException: java.util.concurrent.ExecutionException: org.apache.cassandra.exceptions.ConfigurationException: Column family ID mismatch (found 8347f790-f81a-11e8-a523-0d377e2d0447; expected 83427950-f81a-11e8-a523-0d377e2d0447) | |
| at com.datastax.driver.core.Responses$Error.asException(Responses.java:120) | |
| at com.datastax.driver.core.RequestHandler$SpeculativeExecution.onSet(RequestHandler.java:507) | |
| at com.datastax.driver.core.Connection$Dispatcher.channelRead0(Connection.java:1075) | |
| at com.datastax.driver.core.Connection$Dispatcher.channelRead0(Connection.java:998) | |
| at io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105) | |
| at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) | |
| at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) | |
| at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340) | |
| at io.netty.handler.timeout.IdleStateHandler.channelRead(IdleStateHandler.java:286) | |
| at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) | |
| at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) | |
| at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340) | |
| at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:102) | |
| at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) | |
| at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) | |
| at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340) | |
| at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:310) | |
| at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:284) | |
| at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) | |
| at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) | |
| at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340) | |
| at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1434) | |
| at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) | |
| at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) | |
| at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:965) | |
| at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:163) | |
| at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:628) | |
| at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:563) | |
| at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:480) | |
| at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:442) | |
| at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:884) | |
| at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) | |
| ... 1 common frames omitted | |
| 00:15:52.094 [error] akka.cluster.sharding.PersistentShardCoordinator [sourceThread=auth-impl-application-akka.actor.default-dispatcher-18, akkaTimestamp=23:15:52.067UTC, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/system/sharding/kafkaProducer-token-topicCoordinator/singleton/coordinator, sourceActorSystem=auth-impl-application] - Persistence failure when replaying events for persistenceId [/sharding/kafkaProducer-token-topicCoordinator]. Last known sequence number [0] | |
| java.util.concurrent.ExecutionException: com.datastax.driver.core.exceptions.ServerError: An unexpected error occurred server side on /127.0.0.1:4000: java.lang.RuntimeException: java.util.concurrent.ExecutionException: org.apache.cassandra.exceptions.ConfigurationException: Column family ID mismatch (found 8347f790-f81a-11e8-a523-0d377e2d0447; expected 83427950-f81a-11e8-a523-0d377e2d0447) | |
| at com.google.common.util.concurrent.AbstractFuture.getDoneValue(AbstractFuture.java:503) | |
| at com.google.common.util.concurrent.AbstractFuture.get(AbstractFuture.java:462) | |
| at akka.persistence.cassandra.package$$anon$1.$anonfun$run$1(package.scala:18) | |
| at scala.util.Try$.apply(Try.scala:209) | |
| at akka.persistence.cassandra.package$$anon$1.run(package.scala:18) | |
| at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:40) | |
| at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) | |
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) | |
| at java.lang.Thread.run(Thread.java:748) | |
| Caused by: com.datastax.driver.core.exceptions.ServerError: An unexpected error occurred server side on /127.0.0.1:4000: java.lang.RuntimeException: java.util.concurrent.ExecutionException: org.apache.cassandra.exceptions.ConfigurationException: Column family ID mismatch (found 8347f790-f81a-11e8-a523-0d377e2d0447; expected 83427950-f81a-11e8-a523-0d377e2d0447) | |
| at com.datastax.driver.core.Responses$Error.asException(Responses.java:120) | |
| at com.datastax.driver.core.RequestHandler$SpeculativeExecution.onSet(RequestHandler.java:507) | |
| at com.datastax.driver.core.Connection$Dispatcher.channelRead0(Connection.java:1075) | |
| at com.datastax.driver.core.Connection$Dispatcher.channelRead0(Connection.java:998) | |
| at io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105) | |
| at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) | |
| at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) | |
| at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340) | |
| at io.netty.handler.timeout.IdleStateHandler.channelRead(IdleStateHandler.java:286) | |
| at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) | |
| at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) | |
| at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340) | |
| at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:102) | |
| at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) | |
| at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) | |
| at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340) | |
| at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:310) | |
| at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:284) | |
| at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) | |
| at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) | |
| at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340) | |
| at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1434) | |
| at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) | |
| at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) | |
| at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:965) | |
| at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:163) | |
| at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:628) | |
| at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:563) | |
| at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:480) | |
| at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:442) | |
| at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:884) | |
| at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) | |
| ... 1 common frames omitted | |
| 00:15:52.491 [warn] akka.cluster.sharding.ShardRegion [sourceThread=auth-impl-application-akka.actor.default-dispatcher-2, akkaTimestamp=23:15:52.491UTC, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/system/sharding/kafkaProducer-token-topic, sourceActorSystem=auth-impl-application] - Trying to register to coordinator at [ActorSelection[Anchor(akka://auth-impl-application/), Path(/system/sharding/kafkaProducer-token-topicCoordinator/singleton/coordinator)]], but no acknowledgement. Total [1] buffered messages. [Coordinator [Member(address = akka.tcp://auth-impl-application@127.0.0.1:35917, status = Up)] is reachable.] | |
| 00:15:52.681 [warn] akka.cluster.sharding.ShardRegion [sourceThread=auth-impl-application-akka.actor.default-dispatcher-7, akkaTimestamp=23:15:52.681UTC, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/system/sharding/UserIndexReadSideProcessor, sourceActorSystem=auth-impl-application] - Trying to register to coordinator at [ActorSelection[Anchor(akka://auth-impl-application/), Path(/system/sharding/UserIndexReadSideProcessorCoordinator/singleton/coordinator)]], but no acknowledgement. Total [20] buffered messages. [Coordinator [Member(address = akka.tcp://auth-impl-application@127.0.0.1:35917, status = Up)] is reachable.] | |
| 00:15:53.162 [info] com.lightbend.lagom.internal.persistence.cluster.ClusterStartupTaskActor [sourceThread=auth-impl-application-akka.actor.default-dispatcher-7, akkaTimestamp=23:15:53.162UTC, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/user/readSideGlobalPrepare-UserIndexReadSideProcessor-singleton/singleton/readSideGlobalPrepare-UserIndexReadSideProcessor, sourceActorSystem=auth-impl-application] - Executing cluster start task readSideGlobalPrepare-UserIndexReadSideProcessor. | |
| 00:15:53.213 [error] akka.actor.OneForOneStrategy [sourceThread=auth-impl-application-akka.actor.default-dispatcher-3, akkaTimestamp=23:15:53.173UTC, akkaSource=akka://auth-impl-application/user/readSideGlobalPrepare-UserIndexReadSideProcessor-singleton/singleton/readSideGlobalPrepare-UserIndexReadSideProcessor, sourceActorSystem=auth-impl-application] - com.datastax.driver.core.exceptions.NoHostAvailableException: All host(s) tried for query failed (tried: /127.0.0.1:4000 (com.datastax.driver.core.exceptions.BusyPoolException: [/127.0.0.1] Pool is busy (no available connection and the queue has reached its max size 0))) | |
| java.util.concurrent.ExecutionException: com.datastax.driver.core.exceptions.NoHostAvailableException: All host(s) tried for query failed (tried: /127.0.0.1:4000 (com.datastax.driver.core.exceptions.BusyPoolException: [/127.0.0.1] Pool is busy (no available connection and the queue has reached its max size 0))) | |
| at com.google.common.util.concurrent.AbstractFuture.getDoneValue(AbstractFuture.java:503) | |
| at com.google.common.util.concurrent.AbstractFuture.get(AbstractFuture.java:462) | |
| at akka.persistence.cassandra.package$ListenableFutureConverter$$anon$2.$anonfun$run$2(package.scala:25) | |
| at scala.util.Try$.apply(Try.scala:209) | |
| at akka.persistence.cassandra.package$ListenableFutureConverter$$anon$2.run(package.scala:25) | |
| at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:40) | |
| at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) | |
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) | |
| at java.lang.Thread.run(Thread.java:748) | |
| Caused by: com.datastax.driver.core.exceptions.NoHostAvailableException: All host(s) tried for query failed (tried: /127.0.0.1:4000 (com.datastax.driver.core.exceptions.BusyPoolException: [/127.0.0.1] Pool is busy (no available connection and the queue has reached its max size 0))) | |
| at com.datastax.driver.core.RequestHandler.reportNoMoreHosts(RequestHandler.java:213) | |
| at com.datastax.driver.core.RequestHandler.access$1000(RequestHandler.java:49) | |
| at com.datastax.driver.core.RequestHandler$SpeculativeExecution.findNextHostAndQuery(RequestHandler.java:277) | |
| at com.datastax.driver.core.RequestHandler$SpeculativeExecution$1.onFailure(RequestHandler.java:340) | |
| at com.google.common.util.concurrent.Futures$CallbackListener.run(Futures.java:1228) | |
| at com.google.common.util.concurrent.MoreExecutors$DirectExecutor.execute(MoreExecutors.java:399) | |
| at com.google.common.util.concurrent.AbstractFuture.executeListener(AbstractFuture.java:911) | |
| at com.google.common.util.concurrent.AbstractFuture.addListener(AbstractFuture.java:645) | |
| at com.google.common.util.concurrent.AbstractFuture$TrustedFuture.addListener(AbstractFuture.java:101) | |
| at com.google.common.util.concurrent.Futures.addCallback(Futures.java:1209) | |
| at com.google.common.util.concurrent.Futures.addCallback(Futures.java:1167) | |
| at com.datastax.driver.core.RequestHandler$SpeculativeExecution.query(RequestHandler.java:299) | |
| at com.datastax.driver.core.RequestHandler$SpeculativeExecution.findNextHostAndQuery(RequestHandler.java:274) | |
| at com.datastax.driver.core.RequestHandler.startNewExecution(RequestHandler.java:117) | |
| at com.datastax.driver.core.RequestHandler.sendRequest(RequestHandler.java:97) | |
| at com.datastax.driver.core.SessionManager.executeAsync(SessionManager.java:132) | |
| at com.datastax.driver.core.AbstractSession.executeAsync(AbstractSession.java:76) | |
| at akka.persistence.cassandra.session.scaladsl.CassandraSession.$anonfun$executeCreateTable$1(CassandraSession.scala:215) | |
| at scala.concurrent.Future.$anonfun$flatMap$1(Future.scala:303) | |
| at scala.concurrent.impl.Promise.$anonfun$transformWith$1(Promise.scala:37) | |
| at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60) | |
| at akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:55) | |
| at akka.dispatch.BatchingExecutor$BlockableBatch.$anonfun$run$1(BatchingExecutor.scala:91) | |
| at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:12) | |
| at scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:81) | |
| at akka.dispatch.BatchingExecutor$BlockableBatch.run(BatchingExecutor.scala:91) | |
| ... 4 common frames omitted | |
| 00:15:54.481 [warn] akka.cluster.sharding.ShardRegion [sourceThread=auth-impl-application-akka.actor.default-dispatcher-2, akkaTimestamp=23:15:54.480UTC, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/system/sharding/kafkaProducer-token-topic, sourceActorSystem=auth-impl-application] - Trying to register to coordinator at [ActorSelection[Anchor(akka://auth-impl-application/), Path(/system/sharding/kafkaProducer-token-topicCoordinator/singleton/coordinator)]], but no acknowledgement. Total [1] buffered messages. [Coordinator [Member(address = akka.tcp://auth-impl-application@127.0.0.1:35917, status = Up)] is reachable.] | |
| 00:15:54.681 [warn] akka.cluster.sharding.ShardRegion [sourceThread=auth-impl-application-akka.actor.default-dispatcher-2, akkaTimestamp=23:15:54.681UTC, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/system/sharding/UserIndexReadSideProcessor, sourceActorSystem=auth-impl-application] - Trying to register to coordinator at [ActorSelection[Anchor(akka://auth-impl-application/), Path(/system/sharding/UserIndexReadSideProcessorCoordinator/singleton/coordinator)]], but no acknowledgement. Total [20] buffered messages. [Coordinator [Member(address = akka.tcp://auth-impl-application@127.0.0.1:35917, status = Up)] is reachable.] | |
| 00:15:56.492 [warn] akka.cluster.sharding.ShardRegion [sourceThread=auth-impl-application-akka.actor.default-dispatcher-6, akkaTimestamp=23:15:56.492UTC, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/system/sharding/kafkaProducer-token-topic, sourceActorSystem=auth-impl-application] - Trying to register to coordinator at [ActorSelection[Anchor(akka://auth-impl-application/), Path(/system/sharding/kafkaProducer-token-topicCoordinator/singleton/coordinator)]], but no acknowledgement. Total [1] buffered messages. [Coordinator [Member(address = akka.tcp://auth-impl-application@127.0.0.1:35917, status = Up)] is reachable.] | |
| 00:15:56.681 [warn] akka.cluster.sharding.ShardRegion [sourceThread=auth-impl-application-akka.actor.default-dispatcher-3, akkaTimestamp=23:15:56.681UTC, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/system/sharding/UserIndexReadSideProcessor, sourceActorSystem=auth-impl-application] - Trying to register to coordinator at [ActorSelection[Anchor(akka://auth-impl-application/), Path(/system/sharding/UserIndexReadSideProcessorCoordinator/singleton/coordinator)]], but no acknowledgement. Total [20] buffered messages. [Coordinator [Member(address = akka.tcp://auth-impl-application@127.0.0.1:35917, status = Up)] is reachable.] | |
| 00:15:58.481 [warn] akka.cluster.sharding.ShardRegion [sourceThread=auth-impl-application-akka.actor.default-dispatcher-6, akkaTimestamp=23:15:58.481UTC, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/system/sharding/kafkaProducer-token-topic, sourceActorSystem=auth-impl-application] - Trying to register to coordinator at [ActorSelection[Anchor(akka://auth-impl-application/), Path(/system/sharding/kafkaProducer-token-topicCoordinator/singleton/coordinator)]], but no acknowledgement. Total [1] buffered messages. [Coordinator [Member(address = akka.tcp://auth-impl-application@127.0.0.1:35917, status = Up)] is reachable.] | |
| 00:15:58.680 [warn] akka.cluster.sharding.ShardRegion [sourceThread=auth-impl-application-akka.actor.default-dispatcher-7, akkaTimestamp=23:15:58.680UTC, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/system/sharding/UserIndexReadSideProcessor, sourceActorSystem=auth-impl-application] - Trying to register to coordinator at [ActorSelection[Anchor(akka://auth-impl-application/), Path(/system/sharding/UserIndexReadSideProcessorCoordinator/singleton/coordinator)]], but no acknowledgement. Total [20] buffered messages. [Coordinator [Member(address = akka.tcp://auth-impl-application@127.0.0.1:35917, status = Up)] is reachable.] | |
| 00:15:59.271 [info] com.lightbend.lagom.internal.persistence.cluster.ClusterStartupTaskActor [sourceThread=auth-impl-application-akka.actor.default-dispatcher-3, akkaTimestamp=23:15:59.271UTC, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/user/readSideGlobalPrepare-UserIndexReadSideProcessor-singleton/singleton/readSideGlobalPrepare-UserIndexReadSideProcessor, sourceActorSystem=auth-impl-application] - Executing cluster start task readSideGlobalPrepare-UserIndexReadSideProcessor. | |
| 00:16:00.481 [warn] akka.cluster.sharding.ShardRegion [sourceThread=auth-impl-application-akka.actor.default-dispatcher-2, akkaTimestamp=23:16:00.480UTC, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/system/sharding/kafkaProducer-token-topic, sourceActorSystem=auth-impl-application] - Trying to register to coordinator at [ActorSelection[Anchor(akka://auth-impl-application/), Path(/system/sharding/kafkaProducer-token-topicCoordinator/singleton/coordinator)]], but no acknowledgement. Total [1] buffered messages. [Coordinator [Member(address = akka.tcp://auth-impl-application@127.0.0.1:35917, status = Up)] is reachable.] | |
| 00:16:00.681 [warn] akka.cluster.sharding.ShardRegion [sourceThread=auth-impl-application-akka.actor.default-dispatcher-4, akkaTimestamp=23:16:00.681UTC, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/system/sharding/UserIndexReadSideProcessor, sourceActorSystem=auth-impl-application] - Trying to register to coordinator at [ActorSelection[Anchor(akka://auth-impl-application/), Path(/system/sharding/UserIndexReadSideProcessorCoordinator/singleton/coordinator)]], but no acknowledgement. Total [20] buffered messages. [Coordinator [Member(address = akka.tcp://auth-impl-application@127.0.0.1:35917, status = Up)] is reachable.] | |
| 00:16:02.481 [warn] akka.cluster.sharding.ShardRegion [sourceThread=auth-impl-application-akka.actor.default-dispatcher-7, akkaTimestamp=23:16:02.481UTC, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/system/sharding/kafkaProducer-token-topic, sourceActorSystem=auth-impl-application] - Trying to register to coordinator at [ActorSelection[Anchor(akka://auth-impl-application/), Path(/system/sharding/kafkaProducer-token-topicCoordinator/singleton/coordinator)]], but no acknowledgement. Total [1] buffered messages. [Coordinator [Member(address = akka.tcp://auth-impl-application@127.0.0.1:35917, status = Up)] is reachable.] | |
| 00:16:02.680 [warn] akka.cluster.sharding.ShardRegion [sourceThread=auth-impl-application-akka.actor.default-dispatcher-4, akkaTimestamp=23:16:02.680UTC, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/system/sharding/UserIndexReadSideProcessor, sourceActorSystem=auth-impl-application] - Trying to register to coordinator at [ActorSelection[Anchor(akka://auth-impl-application/), Path(/system/sharding/UserIndexReadSideProcessorCoordinator/singleton/coordinator)]], but no acknowledgement. Total [20] buffered messages. [Coordinator [Member(address = akka.tcp://auth-impl-application@127.0.0.1:35917, status = Up)] is reachable.] | |
| 00:16:04.204 [info] com.lightbend.lagom.internal.persistence.cluster.ClusterStartupTaskActor [sourceThread=auth-impl-application-akka.actor.default-dispatcher-4, akkaTimestamp=23:16:04.204UTC, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/user/readSideGlobalPrepare-UserIndexReadSideProcessor-singleton/singleton/readSideGlobalPrepare-UserIndexReadSideProcessor, sourceActorSystem=auth-impl-application] - Cluster start task readSideGlobalPrepare-UserIndexReadSideProcessor done. | |
| 00:16:04.481 [warn] akka.cluster.sharding.ShardRegion [sourceThread=auth-impl-application-akka.actor.default-dispatcher-4, akkaTimestamp=23:16:04.481UTC, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/system/sharding/kafkaProducer-token-topic, sourceActorSystem=auth-impl-application] - Trying to register to coordinator at [ActorSelection[Anchor(akka://auth-impl-application/), Path(/system/sharding/kafkaProducer-token-topicCoordinator/singleton/coordinator)]], but no acknowledgement. Total [2] buffered messages. [Coordinator [Member(address = akka.tcp://auth-impl-application@127.0.0.1:35917, status = Up)] is reachable.] | |
| 00:16:04.680 [warn] akka.cluster.sharding.ShardRegion [sourceThread=auth-impl-application-akka.actor.default-dispatcher-4, akkaTimestamp=23:16:04.680UTC, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/system/sharding/UserIndexReadSideProcessor, sourceActorSystem=auth-impl-application] - Trying to register to coordinator at [ActorSelection[Anchor(akka://auth-impl-application/), Path(/system/sharding/UserIndexReadSideProcessorCoordinator/singleton/coordinator)]], but no acknowledgement. Total [40] buffered messages. [Coordinator [Member(address = akka.tcp://auth-impl-application@127.0.0.1:35917, status = Up)] is reachable.] | |
| 00:16:06.481 [warn] akka.cluster.sharding.ShardRegion [sourceThread=auth-impl-application-akka.actor.default-dispatcher-2, akkaTimestamp=23:16:06.480UTC, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/system/sharding/kafkaProducer-token-topic, sourceActorSystem=auth-impl-application] - Trying to register to coordinator at [ActorSelection[Anchor(akka://auth-impl-application/), Path(/system/sharding/kafkaProducer-token-topicCoordinator/singleton/coordinator)]], but no acknowledgement. Total [2] buffered messages. [Coordinator [Member(address = akka.tcp://auth-impl-application@127.0.0.1:35917, status = Up)] is reachable.] | |
| 00:16:06.680 [warn] akka.cluster.sharding.ShardRegion [sourceThread=auth-impl-application-akka.actor.default-dispatcher-4, akkaTimestamp=23:16:06.680UTC, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/system/sharding/UserIndexReadSideProcessor, sourceActorSystem=auth-impl-application] - Trying to register to coordinator at [ActorSelection[Anchor(akka://auth-impl-application/), Path(/system/sharding/UserIndexReadSideProcessorCoordinator/singleton/coordinator)]], but no acknowledgement. Total [40] buffered messages. [Coordinator [Member(address = akka.tcp://auth-impl-application@127.0.0.1:35917, status = Up)] is reachable.] | |
| 00:16:07.143 [warn] akka.cluster.sharding.ShardRegion [sourceThread=auth-impl-application-akka.actor.default-dispatcher-3, akkaTimestamp=23:16:07.143UTC, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/system/sharding/UserIndexReadSideProcessor, sourceActorSystem=auth-impl-application] - Retry request for shard [me.aki.fileheaven.auth.impl.AuthEntity$AuthEvent0] homes from coordinator at [Actor[akka://auth-impl-application/system/sharding/UserIndexReadSideProcessorCoordinator/singleton/coordinator#1106161233]]. [2] buffered messages. | |
| 00:16:07.144 [warn] akka.cluster.sharding.ShardRegion [sourceThread=auth-impl-application-akka.actor.default-dispatcher-3, akkaTimestamp=23:16:07.143UTC, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/system/sharding/UserIndexReadSideProcessor, sourceActorSystem=auth-impl-application] - Retry request for shard [me.aki.fileheaven.auth.impl.AuthEntity$AuthEvent1] homes from coordinator at [Actor[akka://auth-impl-application/system/sharding/UserIndexReadSideProcessorCoordinator/singleton/coordinator#1106161233]]. [2] buffered messages. | |
| 00:16:07.144 [warn] akka.cluster.sharding.ShardRegion [sourceThread=auth-impl-application-akka.actor.default-dispatcher-3, akkaTimestamp=23:16:07.143UTC, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/system/sharding/UserIndexReadSideProcessor, sourceActorSystem=auth-impl-application] - Retry request for shard [me.aki.fileheaven.auth.impl.AuthEntity$AuthEvent2] homes from coordinator at [Actor[akka://auth-impl-application/system/sharding/UserIndexReadSideProcessorCoordinator/singleton/coordinator#1106161233]]. [2] buffered messages. | |
| 00:16:07.144 [warn] akka.cluster.sharding.ShardRegion [sourceThread=auth-impl-application-akka.actor.default-dispatcher-3, akkaTimestamp=23:16:07.143UTC, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/system/sharding/UserIndexReadSideProcessor, sourceActorSystem=auth-impl-application] - Retry request for shard [me.aki.fileheaven.auth.impl.AuthEntity$AuthEvent3] homes from coordinator at [Actor[akka://auth-impl-application/system/sharding/UserIndexReadSideProcessorCoordinator/singleton/coordinator#1106161233]]. [2] buffered messages. | |
| 00:16:07.144 [warn] akka.cluster.sharding.ShardRegion [sourceThread=auth-impl-application-akka.actor.default-dispatcher-3, akkaTimestamp=23:16:07.143UTC, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/system/sharding/UserIndexReadSideProcessor, sourceActorSystem=auth-impl-application] - Retry request for shard [me.aki.fileheaven.auth.impl.AuthEntity$AuthEvent11] homes from coordinator at [Actor[akka://auth-impl-application/system/sharding/UserIndexReadSideProcessorCoordinator/singleton/coordinator#1106161233]]. [2] buffered messages. | |
| 00:16:07.144 [warn] akka.cluster.sharding.ShardRegion [sourceThread=auth-impl-application-akka.actor.default-dispatcher-3, akkaTimestamp=23:16:07.143UTC, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/system/sharding/UserIndexReadSideProcessor, sourceActorSystem=auth-impl-application] - Retry request for shard [me.aki.fileheaven.auth.impl.AuthEntity$AuthEvent4] homes from coordinator at [Actor[akka://auth-impl-application/system/sharding/UserIndexReadSideProcessorCoordinator/singleton/coordinator#1106161233]]. [2] buffered messages. | |
| 00:16:07.144 [warn] akka.cluster.sharding.ShardRegion [sourceThread=auth-impl-application-akka.actor.default-dispatcher-3, akkaTimestamp=23:16:07.143UTC, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/system/sharding/UserIndexReadSideProcessor, sourceActorSystem=auth-impl-application] - Retry request for shard [me.aki.fileheaven.auth.impl.AuthEntity$AuthEvent10] homes from coordinator at [Actor[akka://auth-impl-application/system/sharding/UserIndexReadSideProcessorCoordinator/singleton/coordinator#1106161233]]. [2] buffered messages. | |
| 00:16:07.144 [warn] akka.cluster.sharding.ShardRegion [sourceThread=auth-impl-application-akka.actor.default-dispatcher-3, akkaTimestamp=23:16:07.143UTC, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/system/sharding/UserIndexReadSideProcessor, sourceActorSystem=auth-impl-application] - Retry request for shard [me.aki.fileheaven.auth.impl.AuthEntity$AuthEvent5] homes from coordinator at [Actor[akka://auth-impl-application/system/sharding/UserIndexReadSideProcessorCoordinator/singleton/coordinator#1106161233]]. [2] buffered messages. | |
| 00:16:07.144 [warn] akka.cluster.sharding.ShardRegion [sourceThread=auth-impl-application-akka.actor.default-dispatcher-3, akkaTimestamp=23:16:07.143UTC, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/system/sharding/UserIndexReadSideProcessor, sourceActorSystem=auth-impl-application] - Retry request for shard [me.aki.fileheaven.auth.impl.AuthEntity$AuthEvent6] homes from coordinator at [Actor[akka://auth-impl-application/system/sharding/UserIndexReadSideProcessorCoordinator/singleton/coordinator#1106161233]]. [2] buffered messages. | |
| 00:16:07.144 [warn] akka.cluster.sharding.ShardRegion [sourceThread=auth-impl-application-akka.actor.default-dispatcher-3, akkaTimestamp=23:16:07.143UTC, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/system/sharding/UserIndexReadSideProcessor, sourceActorSystem=auth-impl-application] - Retry request for shard [me.aki.fileheaven.auth.impl.AuthEntity$AuthEvent15] homes from coordinator at [Actor[akka://auth-impl-application/system/sharding/UserIndexReadSideProcessorCoordinator/singleton/coordinator#1106161233]]. [2] buffered messages. | |
| 00:16:07.144 [warn] akka.cluster.sharding.ShardRegion [sourceThread=auth-impl-application-akka.actor.default-dispatcher-3, akkaTimestamp=23:16:07.143UTC, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/system/sharding/UserIndexReadSideProcessor, sourceActorSystem=auth-impl-application] - Retry request for shard [me.aki.fileheaven.auth.impl.AuthEntity$AuthEvent7] homes from coordinator at [Actor[akka://auth-impl-application/system/sharding/UserIndexReadSideProcessorCoordinator/singleton/coordinator#1106161233]]. [2] buffered messages. | |
| 00:16:07.144 [warn] akka.cluster.sharding.ShardRegion [sourceThread=auth-impl-application-akka.actor.default-dispatcher-3, akkaTimestamp=23:16:07.143UTC, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/system/sharding/UserIndexReadSideProcessor, sourceActorSystem=auth-impl-application] - Retry request for shard [me.aki.fileheaven.auth.impl.AuthEntity$AuthEvent8] homes from coordinator at [Actor[akka://auth-impl-application/system/sharding/UserIndexReadSideProcessorCoordinator/singleton/coordinator#1106161233]]. [2] buffered messages. | |
| 00:16:07.144 [warn] akka.cluster.sharding.ShardRegion [sourceThread=auth-impl-application-akka.actor.default-dispatcher-3, akkaTimestamp=23:16:07.143UTC, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/system/sharding/UserIndexReadSideProcessor, sourceActorSystem=auth-impl-application] - Retry request for shard [me.aki.fileheaven.auth.impl.AuthEntity$AuthEvent14] homes from coordinator at [Actor[akka://auth-impl-application/system/sharding/UserIndexReadSideProcessorCoordinator/singleton/coordinator#1106161233]]. [2] buffered messages. | |
| 00:16:07.144 [warn] akka.cluster.sharding.ShardRegion [sourceThread=auth-impl-application-akka.actor.default-dispatcher-3, akkaTimestamp=23:16:07.143UTC, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/system/sharding/UserIndexReadSideProcessor, sourceActorSystem=auth-impl-application] - Retry request for shard [me.aki.fileheaven.auth.impl.AuthEntity$AuthEvent13] homes from coordinator at [Actor[akka://auth-impl-application/system/sharding/UserIndexReadSideProcessorCoordinator/singleton/coordinator#1106161233]]. [2] buffered messages. | |
| 00:16:07.145 [warn] akka.cluster.sharding.ShardRegion [sourceThread=auth-impl-application-akka.actor.default-dispatcher-3, akkaTimestamp=23:16:07.143UTC, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/system/sharding/UserIndexReadSideProcessor, sourceActorSystem=auth-impl-application] - Retry request for shard [me.aki.fileheaven.auth.impl.AuthEntity$AuthEvent9] homes from coordinator at [Actor[akka://auth-impl-application/system/sharding/UserIndexReadSideProcessorCoordinator/singleton/coordinator#1106161233]]. [2] buffered messages. | |
| 00:16:07.145 [warn] akka.cluster.sharding.ShardRegion [sourceThread=auth-impl-application-akka.actor.default-dispatcher-3, akkaTimestamp=23:16:07.144UTC, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/system/sharding/UserIndexReadSideProcessor, sourceActorSystem=auth-impl-application] - Retry request for shard [me.aki.fileheaven.auth.impl.AuthEntity$AuthEvent12] homes from coordinator at [Actor[akka://auth-impl-application/system/sharding/UserIndexReadSideProcessorCoordinator/singleton/coordinator#1106161233]]. [2] buffered messages. | |
| 00:16:07.145 [warn] akka.cluster.sharding.ShardRegion [sourceThread=auth-impl-application-akka.actor.default-dispatcher-3, akkaTimestamp=23:16:07.144UTC, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/system/sharding/UserIndexReadSideProcessor, sourceActorSystem=auth-impl-application] - Retry request for shard [me.aki.fileheaven.auth.impl.AuthEntity$AuthEvent19] homes from coordinator at [Actor[akka://auth-impl-application/system/sharding/UserIndexReadSideProcessorCoordinator/singleton/coordinator#1106161233]]. [2] buffered messages. | |
| 00:16:07.145 [warn] akka.cluster.sharding.ShardRegion [sourceThread=auth-impl-application-akka.actor.default-dispatcher-3, akkaTimestamp=23:16:07.144UTC, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/system/sharding/UserIndexReadSideProcessor, sourceActorSystem=auth-impl-application] - Retry request for shard [me.aki.fileheaven.auth.impl.AuthEntity$AuthEvent18] homes from coordinator at [Actor[akka://auth-impl-application/system/sharding/UserIndexReadSideProcessorCoordinator/singleton/coordinator#1106161233]]. [2] buffered messages. | |
| 00:16:07.145 [warn] akka.cluster.sharding.ShardRegion [sourceThread=auth-impl-application-akka.actor.default-dispatcher-3, akkaTimestamp=23:16:07.144UTC, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/system/sharding/UserIndexReadSideProcessor, sourceActorSystem=auth-impl-application] - Retry request for shard [me.aki.fileheaven.auth.impl.AuthEntity$AuthEvent17] homes from coordinator at [Actor[akka://auth-impl-application/system/sharding/UserIndexReadSideProcessorCoordinator/singleton/coordinator#1106161233]]. [2] buffered messages. | |
| 00:16:07.145 [warn] akka.cluster.sharding.ShardRegion [sourceThread=auth-impl-application-akka.actor.default-dispatcher-3, akkaTimestamp=23:16:07.144UTC, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/system/sharding/UserIndexReadSideProcessor, sourceActorSystem=auth-impl-application] - Retry request for shard [me.aki.fileheaven.auth.impl.AuthEntity$AuthEvent16] homes from coordinator at [Actor[akka://auth-impl-application/system/sharding/UserIndexReadSideProcessorCoordinator/singleton/coordinator#1106161233]]. [2] buffered messages. | |
| 00:16:08.492 [warn] akka.cluster.sharding.ShardRegion [sourceThread=auth-impl-application-akka.actor.default-dispatcher-2, akkaTimestamp=23:16:08.492UTC, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/system/sharding/kafkaProducer-token-topic, sourceActorSystem=auth-impl-application] - Trying to register to coordinator at [ActorSelection[Anchor(akka://auth-impl-application/), Path(/system/sharding/kafkaProducer-token-topicCoordinator/singleton/coordinator)]], but no acknowledgement. Total [2] buffered messages. [Coordinator [Member(address = akka.tcp://auth-impl-application@127.0.0.1:35917, status = Up)] is reachable.] | |
| 00:16:08.541 [warn] akka.cluster.sharding.ShardRegion [sourceThread=auth-impl-application-akka.actor.default-dispatcher-7, akkaTimestamp=23:16:08.541UTC, akkaSource=akka.tcp://auth-impl-application@127.0.0.1:35917/system/sharding/kafkaProducer-token-topic, sourceActorSystem=auth-impl-application] - Retry request for shard [singleton] homes from coordinator at [Actor[akka://auth-impl-application/system/sharding/kafkaProducer-token-topicCoordinator/singleton/coordinator#933109585]]. [2] buffered messages. |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment