Hello,
In a multi node cluster sharding scenario if a persistent actor throws an
exception, it is not propagating to the Parent Actor supervisor strategy,
instead the persistent actor retries for ever, I haven't tried the
BackOffSupervisor yet but does it help in propagating the exception to the
parent actor or it periodically increases the timeout and tries again and
again till the exception is resolved.
Ideally, if there is a database exception in the persistent actor, i would
like the supervisor actor open the circuit breaker. So, far I haven't had
much success in getting this to work.
I looked at the following thread, looks like this has been resolved in Akka
2.4 release.
https://github.com/akka/akka/issues/18487
I took an example from this URL
(https://github.com/henrymai/akka/blob/master/akka-cluster-sharding/src/test/java/akka/cluster/sharding/ClusterShardingTest.java)
and added an exception scenario to test the exception propagation scenario
but it is not working as expected instead re-tries for ever following is
the sample log.
My changes can be found at this github URL
(https://github.com/sdab75/akka-cluster-sharding-test/blob/master/src/main/java/akka/cluster/sharding/ClusterShardingTest.java),
this example will recreate the exception i was talking about.
I am just wondering, if any of got this scenario working. Appreciate any
help in resolving this issue.
I generate the exception the following way.
void updateState(CounterChanged event) {
System.out.println("updating ###################");
if(true){
throw new RuntimeException("Intentional Error
@@@@@@@@@@@@@@@@@@@@@@@@");
}
count += event.delta;
}
Error Log:
C:\java\jdk1.8.0_25\bin\java -Didea.launcher.port=7533
"-Didea.launcher.bin.path=C:\Program Files (x86)\JetBrains\IntelliJ IDEA
Community Edition 14.1.5\bin" -Dfile.encoding=windows-1252 -classpath
"C:\java\jdk1.8.0_25\jre\lib\charsets.jar;C:\java\jdk1.8.0_25\jre\lib\deploy.jar;C:\java\jdk1.8.0_25\jre\lib\javaws.jar;C:\java\jdk1.8.0_25\jre\lib\jce.jar;C:\java\jdk1.8.0_25\jre\lib\jfr.jar;C:\java\jdk1.8.0_25\jre\lib\jfxswt.jar;C:\java\jdk1.8.0_25\jre\lib\jsse.jar;C:\java\jdk1.8.0_25\jre\lib\management-agent.jar;C:\java\jdk1.8.0_25\jre\lib\plugin.jar;C:\java\jdk1.8.0_25\jre\lib\resources.jar;C:\java\jdk1.8.0_25\jre\lib\rt.jar;C:\java\jdk1.8.0_25\jre\lib\ext\access-bridge-64.jar;C:\java\jdk1.8.0_25\jre\lib\ext\cldrdata.jar;C:\java\jdk1.8.0_25\jre\lib\ext\dnsns.jar;C:\java\jdk1.8.0_25\jre\lib\ext\jaccess.jar;C:\java\jdk1.8.0_25\jre\lib\ext\jfxrt.jar;C:\java\jdk1.8.0_25\jre\lib\ext\localedata.jar;C:\java\jdk1.8.0_25\jre\lib\ext\nashorn.jar;C:\java\jdk1.8.0_25\jre\lib\ext\sapjco3.jar;C:\java\jdk1.8.0_25\jre\lib\ext\sunec.jar;C:\java\jdk1.8.0_25\jre\lib\ext\sunjce_provider.jar;C:\java\jdk1.8.0_25\jre\lib\ext\sunmscapi.jar;C:\java\jdk1.8.0_25\jre\lib\ext\sunpkcs11.jar;C:\java\jdk1.8.0_25\jre\lib\ext\zipfs.jar;C:\dev\garnet\experiments\akka-cluster-sharding-test\target\classes;C:\Users\davenkat\.m2\repository\org\codehaus\jackson\jackson-mapper-asl\1.9.11\jackson-mapper-asl-1.9.11.jar;C:\Users\davenkat\.m2\repository\org\codehaus\jackson\jackson-core-asl\1.9.11\jackson-core-asl-1.9.11.jar;C:\Users\davenkat\.m2\repository\javax\json\javax.json-api\1.0\javax.json-api-1.0.jar;C:\Users\davenkat\.m2\repository\org\springframework\boot\spring-boot-starter-web\1.2.5.RELEASE\spring-boot-starter-web-1.2.5.RELEASE.jar;C:\Users\davenkat\.m2\repository\org\springframework\boot\spring-boot-starter\1.2.5.RELEASE\spring-boot-starter-1.2.5.RELEASE.jar;C:\Users\davenkat\.m2\repository\org\springframework\boot\spring-boot\1.2.5.RELEASE\spring-boot-1.2.5.RELEASE.jar;C:\Users\davenkat\.m2\repository\org\springframework\boot\spring-boot-autoconfigure\1.2.5.RELEASE\spring-boot-autoconfigure-1.2.5.RELEASE.jar;C:\Users\davenkat\.m2\repository\org\springframework\boot\spring-boot-starter-logging\1.2.5.RELEASE\spring-boot-starter-logging-1.2.5.RELEASE.jar;C:\Users\davenkat\.m2\repository\org\slf4j\jul-to-slf4j\1.7.12\jul-to-slf4j-1.7.12.jar;C:\Users\davenkat\.m2\repository\org\yaml\snakeyaml\1.14\snakeyaml-1.14.jar;C:\Users\davenkat\.m2\repository\org\springframework\boot\spring-boot-starter-tomcat\1.2.5.RELEASE\spring-boot-starter-tomcat-1.2.5.RELEASE.jar;C:\Users\davenkat\.m2\repository\org\apache\tomcat\embed\tomcat-embed-core\8.0.23\tomcat-embed-core-8.0.23.jar;C:\Users\davenkat\.m2\repository\org\apache\tomcat\embed\tomcat-embed-el\8.0.23\tomcat-embed-el-8.0.23.jar;C:\Users\davenkat\.m2\repository\org\apache\tomcat\embed\tomcat-embed-logging-juli\8.0.23\tomcat-embed-logging-juli-8.0.23.jar;C:\Users\davenkat\.m2\repository\org\apache\tomcat\embed\tomcat-embed-websocket\8.0.23\tomcat-embed-websocket-8.0.23.jar;C:\Users\davenkat\.m2\repository\com\fasterxml\jackson\core\jackson-databind\2.4.6\jackson-databind-2.4.6.jar;C:\Users\davenkat\.m2\repository\com\fasterxml\jackson\core\jackson-core\2.4.6\jackson-core-2.4.6.jar;C:\Users\davenkat\.m2\repository\org\springframework\spring-core\4.1.7.RELEASE\spring-core-4.1.7.RELEASE.jar;C:\Users\davenkat\.m2\repository\org\springframework\spring-web\4.1.7.RELEASE\spring-web-4.1.7.RELEASE.jar;C:\Users\davenkat\.m2\repository\org\springframework\spring-webmvc\4.1.7.RELEASE\spring-webmvc-4.1.7.RELEASE.jar;C:\Users\davenkat\.m2\repository\org\springframework\data\spring-data-rest-webmvc\2.2.3.RELEASE\spring-data-rest-webmvc-2.2.3.RELEASE.jar;C:\Users\davenkat\.m2\repository\org\springframework\data\spring-data-rest-core\2.2.3.RELEASE\spring-data-rest-core-2.2.3.RELEASE.jar;C:\Users\davenkat\.m2\repository\org\springframework\hateoas\spring-hateoas\0.16.0.RELEASE\spring-hateoas-0.16.0.RELEASE.jar;C:\Users\davenkat\.m2\repository\org\springframework\plugin\spring-plugin-core\1.1.0.RELEASE\spring-plugin-core-1.1.0.RELEASE.jar;C:\Users\davenkat\.m2\repository\org\atteo\evo-inflector\1.2\evo-inflector-1.2.jar;C:\Users\davenkat\.m2\repository\com\fasterxml\jackson\core\jackson-annotations\2.4.6\jackson-annotations-2.4.6.jar;C:\Users\davenkat\.m2\repository\com\github\fge\json-patch\1.7\json-patch-1.7.jar;C:\Users\davenkat\.m2\repository\com\github\fge\jackson-coreutils\1.6\jackson-coreutils-1.6.jar;C:\Users\davenkat\.m2\repository\com\github\fge\msg-simple\1.1\msg-simple-1.1.jar;C:\Users\davenkat\.m2\repository\com\github\fge\btf\1.2\btf-1.2.jar;C:\Users\davenkat\.m2\repository\com\google\code\findbugs\jsr305\2.0.1\jsr305-2.0.1.jar;C:\Users\davenkat\.m2\repository\org\slf4j\slf4j-api\1.7.12\slf4j-api-1.7.12.jar;C:\Users\davenkat\.m2\repository\org\slf4j\jcl-over-slf4j\1.7.12\jcl-over-slf4j-1.7.12.jar;C:\Users\davenkat\.m2\repository\org\springframework\data\spring-data-hadoop\2.2.0.RELEASE\spring-data-hadoop-2.2.0.RELEASE.jar;C:\Users\davenkat\.m2\repository\org\springframework\spring-context-support\4.1.7.RELEASE\spring-context-support-4.1.7.RELEASE.jar;C:\Users\davenkat\.m2\repository\org\springframework\spring-aop\4.1.7.RELEASE\spring-aop-4.1.7.RELEASE.jar;C:\Users\davenkat\.m2\repository\aopalliance\aopalliance\1.0\aopalliance-1.0.jar;C:\Users\davenkat\.m2\repository\org\springframework\spring-tx\4.1.7.RELEASE\spring-tx-4.1.7.RELEASE.jar;C:\Users\davenkat\.m2\repository\org\springframework\data\spring-data-hadoop-hbase\2.2.0.RELEASE\spring-data-hadoop-hbase-2.2.0.RELEASE.jar;C:\Users\davenkat\.m2\repository\org\apache\hadoop\hadoop-yarn-common\2.6.0\hadoop-yarn-common-2.6.0.jar;C:\Users\davenkat\.m2\repository\org\apache\hadoop\hadoop-yarn-api\2.6.0\hadoop-yarn-api-2.6.0.jar;C:\Users\davenkat\.m2\repository\javax\xml\bind\jaxb-api\2.2.2\jaxb-api-2.2.2.jar;C:\Users\davenkat\.m2\repository\javax\xml\stream\stax-api\1.0-2\stax-api-1.0-2.jar;C:\Users\davenkat\.m2\repository\javax\activation\activation\1.1\activation-1.1.jar;C:\Users\davenkat\.m2\repository\org\apache\commons\commons-compress\1.4.1\commons-compress-1.4.1.jar;C:\Users\davenkat\.m2\repository\org\tukaani\xz\1.0\xz-1.0.jar;C:\Users\davenkat\.m2\repository\commons-lang\commons-lang\2.6\commons-lang-2.6.jar;C:\Users\davenkat\.m2\repository\javax\servlet\servlet-api\2.5\servlet-api-2.5.jar;C:\Users\davenkat\.m2\repository\commons-codec\commons-codec\1.4\commons-codec-1.4.jar;C:\Users\davenkat\.m2\repository\org\mortbay\jetty\jetty-util\6.1.26\jetty-util-6.1.26.jar;C:\Users\davenkat\.m2\repository\com\sun\jersey\jersey-core\1.9\jersey-core-1.9.jar;C:\Users\davenkat\.m2\repository\com\sun\jersey\jersey-client\1.9\jersey-client-1.9.jar;C:\Users\davenkat\.m2\repository\org\codehaus\jackson\jackson-jaxrs\1.9.13\jackson-jaxrs-1.9.13.jar;C:\Users\davenkat\.m2\repository\org\codehaus\jackson\jackson-xc\1.9.13\jackson-xc-1.9.13.jar;C:\Users\davenkat\.m2\repository\commons-logging\commons-logging\1.1.3\commons-logging-1.1.3.jar;C:\Users\davenkat\.m2\repository\commons-cli\commons-cli\1.2\commons-cli-1.2.jar;C:\Users\davenkat\.m2\repository\org\apache\hadoop\hadoop-annotations\2.6.0\hadoop-annotations-2.6.0.jar;C:\Users\davenkat\.m2\repository\com\google\inject\extensions\guice-servlet\3.0\guice-servlet-3.0.jar;C:\Users\davenkat\.m2\repository\com\google\protobuf\protobuf-java\2.5.0\protobuf-java-2.5.0.jar;C:\Users\davenkat\.m2\repository\commons-io\commons-io\2.4\commons-io-2.4.jar;C:\Users\davenkat\.m2\repository\com\google\inject\guice\3.0\guice-3.0.jar;C:\Users\davenkat\.m2\repository\javax\inject\javax.inject\1\javax.inject-1.jar;C:\Users\davenkat\.m2\repository\com\sun\jersey\jersey-server\1.9\jersey-server-1.9.jar;C:\Users\davenkat\.m2\repository\com\sun\jersey\jersey-json\1.9\jersey-json-1.9.jar;C:\Users\davenkat\.m2\repository\com\sun\xml\bind\jaxb-impl\2.2.3-1\jaxb-impl-2.2.3-1.jar;C:\Users\davenkat\.m2\repository\com\sun\jersey\contribs\jersey-guice\1.9\jersey-guice-1.9.jar;C:\Users\davenkat\.m2\repository\org\apache\hadoop\hadoop-common\2.6.0\hadoop-common-2.6.0.jar;C:\Users\davenkat\.m2\repository\org\apache\commons\commons-math3\3.1.1\commons-math3-3.1.1.jar;C:\Users\davenkat\.m2\repository\xmlenc\xmlenc\0.52\xmlenc-0.52.jar;C:\Users\davenkat\.m2\repository\commons-httpclient\commons-httpclient\3.1\commons-httpclient-3.1.jar;C:\Users\davenkat\.m2\repository\commons-net\commons-net\3.1\commons-net-3.1.jar;C:\Users\davenkat\.m2\repository\commons-collections\commons-collections\3.2.1\commons-collections-3.2.1.jar;C:\Users\davenkat\.m2\repository\org\mortbay\jetty\jetty\6.1.26\jetty-6.1.26.jar;C:\Users\davenkat\.m2\repository\tomcat\jasper-compiler\5.5.23\jasper-compiler-5.5.23.jar;C:\Users\davenkat\.m2\repository\tomcat\jasper-runtime\5.5.23\jasper-runtime-5.5.23.jar;C:\Users\davenkat\.m2\repository\javax\servlet\jsp\jsp-api\2.1\jsp-api-2.1.jar;C:\Users\davenkat\.m2\repository\commons-el\commons-el\1.0\commons-el-1.0.jar;C:\Users\davenkat\.m2\repository\net\java\dev\jets3t\jets3t\0.9.0\jets3t-0.9.0.jar;C:\Users\davenkat\.m2\repository\org\apache\httpcomponents\httpclient\4.3.6\httpclient-4.3.6.jar;C:\Users\davenkat\.m2\repository\org\apache\httpcomponents\httpcore\4.1.2\httpcore-4.1.2.jar;C:\Users\davenkat\.m2\repository\com\jamesmurty\utils\java-xmlbuilder\0.4\java-xmlbuilder-0.4.jar;C:\Users\davenkat\.m2\repository\commons-configuration\commons-configuration\1.6\commons-configuration-1.6.jar;C:\Users\davenkat\.m2\repository\commons-digester\commons-digester\2.1\commons-digester-2.1.jar;C:\Users\davenkat\.m2\repository\commons-beanutils\commons-beanutils\1.9.2\commons-beanutils-1.9.2.jar;C:\Users\davenkat\.m2\repository\commons-beanutils\commons-beanutils-core\1.8.0\commons-beanutils-core-1.8.0.jar;C:\Users\davenkat\.m2\repository\org\apache\avro\avro\1.7.4\avro-1.7.4.jar;C:\Users\davenkat\.m2\repository\com\thoughtworks\paranamer\paranamer\2.3\paranamer-2.3.jar;C:\Users\davenkat\.m2\repository\org\xerial\snappy\snappy-java\1.0.4.1\snappy-java-1.0.4.1.jar;C:\Users\davenkat\.m2\repository\com\google\code\gson\gson\2.3.1\gson-2.3.1.jar;C:\Users\davenkat\.m2\repository\org\apache\hadoop\hadoop-auth\2.6.0\hadoop-auth-2.6.0.jar;C:\Users\davenkat\.m2\repository\org\apache\directory\server\apacheds-kerberos-codec\2.0.0-M15\apacheds-kerberos-codec-2.0.0-M15.jar;C:\Users\davenkat\.m2\repository\org\apache\directory\server\apacheds-i18n\2.0.0-M15\apacheds-i18n-2.0.0-M15.jar;C:\Users\davenkat\.m2\repository\org\apache\directory\api\api-asn1-api\1.0.0-M20\api-asn1-api-1.0.0-M20.jar;C:\Users\davenkat\.m2\repository\org\apache\directory\api\api-util\1.0.0-M20\api-util-1.0.0-M20.jar;C:\Users\davenkat\.m2\repository\org\apache\curator\curator-framework\2.6.0\curator-framework-2.6.0.jar;C:\Users\davenkat\.m2\repository\com\jcraft\jsch\0.1.42\jsch-0.1.42.jar;C:\Users\davenkat\.m2\repository\org\apache\curator\curator-client\2.6.0\curator-client-2.6.0.jar;C:\Users\davenkat\.m2\repository\org\apache\curator\curator-recipes\2.6.0\curator-recipes-2.6.0.jar;C:\Users\davenkat\.m2\repository\org\htrace\htrace-core\3.0.4\htrace-core-3.0.4.jar;C:\Users\davenkat\.m2\repository\org\apache\zookeeper\zookeeper\3.4.6\zookeeper-3.4.6.jar;C:\Users\davenkat\.m2\repository\org\apache\hadoop\hadoop-distcp\2.6.0\hadoop-distcp-2.6.0.jar;C:\Users\davenkat\.m2\repository\org\apache\hadoop\hadoop-hdfs\2.6.0\hadoop-hdfs-2.6.0.jar;C:\Users\davenkat\.m2\repository\commons-daemon\commons-daemon\1.0.13\commons-daemon-1.0.13.jar;C:\Users\davenkat\.m2\repository\xerces\xercesImpl\2.9.1\xercesImpl-2.9.1.jar;C:\Users\davenkat\.m2\repository\xml-apis\xml-apis\1.3.04\xml-apis-1.3.04.jar;C:\Users\davenkat\.m2\repository\org\apache\hadoop\hadoop-mapreduce-client-core\2.6.0\hadoop-mapreduce-client-core-2.6.0.jar;C:\Users\davenkat\.m2\repository\org\apache\hadoop\hadoop-streaming\2.6.0\hadoop-streaming-2.6.0.jar;C:\Users\davenkat\.m2\repository\org\apache\hadoop\hadoop-mapreduce-client-jobclient\2.6.0\hadoop-mapreduce-client-jobclient-2.6.0.jar;C:\Users\davenkat\.m2\repository\org\apache\hadoop\hadoop-mapreduce-client-common\2.6.0\hadoop-mapreduce-client-common-2.6.0.jar;C:\Users\davenkat\.m2\repository\org\apache\hadoop\hadoop-yarn-client\2.6.0\hadoop-yarn-client-2.6.0.jar;C:\Users\davenkat\.m2\repository\org\apache\hadoop\hadoop-yarn-server-common\2.6.0\hadoop-yarn-server-common-2.6.0.jar;C:\Users\davenkat\.m2\repository\org\apache\hadoop\hadoop-mapreduce-client-shuffle\2.6.0\hadoop-mapreduce-client-shuffle-2.6.0.jar;C:\Users\davenkat\.m2\repository\org\apache\hadoop\hadoop-yarn-server-nodemanager\2.6.0\hadoop-yarn-server-nodemanager-2.6.0.jar;C:\Users\davenkat\.m2\repository\org\fusesource\leveldbjni\leveldbjni-all\1.8\leveldbjni-all-1.8.jar;C:\Users\davenkat\.m2\repository\org\springframework\data\spring-data-hadoop-pig\2.2.0.RELEASE\spring-data-hadoop-pig-2.2.0.RELEASE.jar;C:\Users\davenkat\.m2\repository\org\springframework\batch\spring-batch-core\3.0.4.RELEASE\spring-batch-core-3.0.4.RELEASE.jar;C:\Users\davenkat\.m2\repository\com\ibm\jbatch\com.ibm.jbatch-tck-spi\1.0\com.ibm.jbatch-tck-spi-1.0.jar;C:\Users\davenkat\.m2\repository\javax\batch\javax.batch-api\1.0\javax.batch-api-1.0.jar;C:\Users\davenkat\.m2\repository\com\thoughtworks\xstream\xstream\1.4.7\xstream-1.4.7.jar;C:\Users\davenkat\.m2\repository\xmlpull\xmlpull\1.1.3.1\xmlpull-1.1.3.1.jar;C:\Users\davenkat\.m2\repository\xpp3\xpp3_min\1.1.4c\xpp3_min-1.1.4c.jar;C:\Users\davenkat\.m2\repository\org\codehaus\jettison\jettison\1.2\jettison-1.2.jar;C:\Users\davenkat\.m2\repository\org\springframework\batch\spring-batch-infrastructure\3.0.4.RELEASE\spring-batch-infrastructure-3.0.4.RELEASE.jar;C:\Users\davenkat\.m2\repository\org\springframework\data\spring-data-hadoop-batch\2.2.0.RELEASE\spring-data-hadoop-batch-2.2.0.RELEASE.jar;C:\Users\davenkat\.m2\repository\org\springframework\data\spring-data-hadoop-hive\2.2.0.RELEASE\spring-data-hadoop-hive-2.2.0.RELEASE.jar;C:\Users\davenkat\.m2\repository\org\springframework\spring-context\4.1.7.RELEASE\spring-context-4.1.7.RELEASE.jar;C:\Users\davenkat\.m2\repository\org\springframework\spring-jdbc\4.1.7.RELEASE\spring-jdbc-4.1.7.RELEASE.jar;C:\Users\davenkat\.m2\repository\org\springframework\data\spring-data-hadoop-core\2.2.0.RELEASE\spring-data-hadoop-core-2.2.0.RELEASE.jar;C:\Users\davenkat\.m2\repository\org\springframework\data\spring-data-cassandra\1.2.2.RELEASE\spring-data-cassandra-1.2.2.RELEASE.jar;C:\Users\davenkat\.m2\repository\org\springframework\spring-expression\4.1.7.RELEASE\spring-expression-4.1.7.RELEASE.jar;C:\Users\davenkat\.m2\repository\org\springframework\data\spring-data-commons\1.9.3.RELEASE\spring-data-commons-1.9.3.RELEASE.jar;C:\Users\davenkat\.m2\repository\com\datastax\cassandra\cassandra-driver-dse\2.1.5\cassandra-driver-dse-2.1.5.jar;C:\Users\davenkat\.m2\repository\org\springframework\data\spring-cql\1.2.2.RELEASE\spring-cql-1.2.2.RELEASE.jar;C:\Users\davenkat\.m2\repository\org\springframework\spring-beans\4.1.7.RELEASE\spring-beans-4.1.7.RELEASE.jar;C:\Users\davenkat\.m2\repository\com\google\guava\guava\16.0.1\guava-16.0.1.jar;C:\Users\davenkat\.m2\repository\org\springframework\boot\spring-boot-starter-amqp\1.2.5.RELEASE\spring-boot-starter-amqp-1.2.5.RELEASE.jar;C:\Users\davenkat\.m2\repository\org\springframework\spring-messaging\4.1.7.RELEASE\spring-messaging-4.1.7.RELEASE.jar;C:\Users\davenkat\.m2\repository\org\springframework\amqp\spring-rabbit\1.4.5.RELEASE\spring-rabbit-1.4.5.RELEASE.jar;C:\Users\davenkat\.m2\repository\com\rabbitmq\amqp-client\3.5.1\amqp-client-3.5.1.jar;C:\Users\davenkat\.m2\repository\org\springframework\retry\spring-retry\1.1.2.RELEASE\spring-retry-1.1.2.RELEASE.jar;C:\Users\davenkat\.m2\repository\org\springframework\amqp\spring-amqp\1.4.5.RELEASE\spring-amqp-1.4.5.RELEASE.jar;C:\Users\davenkat\.m2\repository\org\springframework\data\spring-data-redis\1.5.2.RELEASE\spring-data-redis-1.5.2.RELEASE.jar;C:\Users\davenkat\.m2\repository\redis\clients\jedis\2.7.0\jedis-2.7.0.jar;C:\Users\davenkat\.m2\repository\org\apache\commons\commons-pool2\2.2\commons-pool2-2.2.jar;C:\Users\davenkat\.m2\repository\asm\asm\3.3.1\asm-3.3.1.jar;C:\Users\davenkat\.m2\repository\org\objenesis\objenesis\2.1\objenesis-2.1.jar;C:\Users\davenkat\.m2\repository\org\mapstruct\mapstruct\1.0.0.CR1\mapstruct-1.0.0.CR1.jar;C:\Users\davenkat\.m2\repository\org\hibernate\hibernate-validator\5.1.3.Final\hibernate-validator-5.1.3.Final.jar;C:\Users\davenkat\.m2\repository\javax\validation\validation-api\1.1.0.Final\validation-api-1.1.0.Final.jar;C:\Users\davenkat\.m2\repository\org\jboss\logging\jboss-logging\3.1.3.GA\jboss-logging-3.1.3.GA.jar;C:\Users\davenkat\.m2\repository\com\fasterxml\classmate\1.0.0\classmate-1.0.0.jar;C:\Users\davenkat\.m2\repository\com\typesafe\akka\akka-actor_2.11\2.4.0\akka-actor_2.11-2.4.0.jar;C:\Users\davenkat\.m2\repository\org\scala-lang\scala-library\2.11.7\scala-library-2.11.7.jar;C:\Users\davenkat\.m2\repository\com\typesafe\config\1.3.0\config-1.3.0.jar;C:\Users\davenkat\.m2\repository\com\typesafe\akka\akka-remote_2.11\2.4.0\akka-remote_2.11-2.4.0.jar;C:\Users\davenkat\.m2\repository\com\typesafe\akka\akka-protobuf_2.11\2.4.0\akka-protobuf_2.11-2.4.0.jar;C:\Users\davenkat\.m2\repository\io\netty\netty\3.10.3.Final\netty-3.10.3.Final.jar;C:\Users\davenkat\.m2\repository\org\uncommons\maths\uncommons-maths\1.2.2a\uncommons-maths-1.2.2a.jar;C:\Users\davenkat\.m2\repository\com\typesafe\akka\akka-cluster_2.11\2.4.0\akka-cluster_2.11-2.4.0.jar;C:\Users\davenkat\.m2\repository\com\typesafe\akka\akka-contrib_2.11\2.4.0\akka-contrib_2.11-2.4.0.jar;C:\Users\davenkat\.m2\repository\com\typesafe\akka\akka-cluster-tools_2.11\2.4.0\akka-cluster-tools_2.11-2.4.0.jar;C:\Users\davenkat\.m2\repository\com\typesafe\akka\akka-persistence_2.11\2.4.0\akka-persistence_2.11-2.4.0.jar;C:\Users\davenkat\.m2\repository\com\typesafe\akka\akka-cluster-sharding_2.11\2.4.0\akka-cluster-sharding_2.11-2.4.0.jar;C:\Users\davenkat\.m2\repository\com\github\krasserm\akka-persistence-cassandra_2.11\0.4\akka-persistence-cassandra_2.11-0.4.jar;C:\Users\davenkat\.m2\repository\com\datastax\cassandra\cassandra-driver-core\2.1.5\cassandra-driver-core-2.1.5.jar;C:\Users\davenkat\.m2\repository\com\codahale\metrics\metrics-core\3.0.2\metrics-core-3.0.2.jar;C:\Program
Files (x86)\JetBrains\IntelliJ IDEA Community Edition
14.1.5\lib\idea_rt.jar" com.intellij.rt.execution.application.AppMain
akka.cluster.sharding.ClusterShardingTest
[INFO] [11/11/2015 21:53:21.760] [main] [akka.remote.Remoting] Starting
remoting
[INFO] [11/11/2015 21:53:21.949] [main] [akka.remote.Remoting] Remoting
started; listening on addresses :[akka.tcp://[email protected]:2550]
[INFO] [11/11/2015 21:53:21.951] [main] [akka.remote.Remoting] Remoting now
listens on addresses: [akka.tcp://[email protected]:2550]
[INFO] [11/11/2015 21:53:21.962] [main]
[akka.cluster.Cluster(akka://ClusterSystem)] Cluster Node
[akka.tcp://[email protected]:2550] - Starting up...
[INFO] [11/11/2015 21:53:22.035] [main]
[akka.cluster.Cluster(akka://ClusterSystem)] Cluster Node
[akka.tcp://[email protected]:2550] - Registered cluster JMX MBean
[akka:type=Cluster]
[INFO] [11/11/2015 21:53:22.035] [main]
[akka.cluster.Cluster(akka://ClusterSystem)] Cluster Node
[akka.tcp://[email protected]:2550] - Started up successfully
[INFO] [11/11/2015 21:53:22.041]
[ClusterSystem-akka.actor.default-dispatcher-3]
[akka.cluster.Cluster(akka://ClusterSystem)] Cluster Node
[akka.tcp://[email protected]:2550] - Metrics will be retreived from
MBeans, and may be incorrect on some platforms. To increase metric accuracy
add the 'sigar.jar' to the classpath and the appropriate platform-specific
native libary to 'java.library.path'. Reason:
java.lang.ClassNotFoundException: org.hyperic.sigar.Sigar
[INFO] [11/11/2015 21:53:22.045]
[ClusterSystem-akka.actor.default-dispatcher-3]
[akka.cluster.Cluster(akka://ClusterSystem)] Cluster Node
[akka.tcp://[email protected]:2550] - Metrics collection has started
successfully
[INFO] [11/11/2015 21:53:22.081]
[ClusterSystem-akka.actor.default-dispatcher-4]
[akka.cluster.Cluster(akka://ClusterSystem)] Cluster Node
[akka.tcp://[email protected]:2550] - Node
[akka.tcp://[email protected]:2550] is JOINING, roles []
[INFO] [11/11/2015 21:53:23.082]
[ClusterSystem-akka.actor.default-dispatcher-15]
[akka.cluster.Cluster(akka://ClusterSystem)] Cluster Node
[akka.tcp://[email protected]:2550] - Leader is moving node
[akka.tcp://[email protected]:2550] to [Up]
[INFO] [11/11/2015 21:53:23.146]
[ClusterSystem-akka.actor.default-dispatcher-19]
[akka.tcp://[email protected]:2550/system/sharding/SupervisedCounterCoordinator]
Singleton manager starting singleton actor
[akka://ClusterSystem/system/sharding/SupervisedCounterCoordinator/singleton]
[INFO] [11/11/2015 21:53:23.146]
[ClusterSystem-akka.actor.default-dispatcher-18]
[akka.tcp://[email protected]:2550/system/sharding/CounterCoordinator]
Singleton manager starting singleton actor
[akka://ClusterSystem/system/sharding/CounterCoordinator/singleton]
[INFO] [11/11/2015 21:53:23.147]
[ClusterSystem-akka.actor.default-dispatcher-18]
[akka.tcp://[email protected]:2550/system/sharding/CounterCoordinator]
ClusterSingletonManager state change [Start -> Oldest]
[INFO] [11/11/2015 21:53:23.147]
[ClusterSystem-akka.actor.default-dispatcher-19]
[akka.tcp://[email protected]:2550/system/sharding/SupervisedCounterCoordinator]
ClusterSingletonManager state change [Start -> Oldest]
[INFO] [11/11/2015 21:53:23.147]
[ClusterSystem-akka.actor.default-dispatcher-15]
[akka://ClusterSystem/system/sharding/CounterCoordinator/singleton/coordinator]
Message [akka.cluster.sharding.ShardCoordinator$Internal$Register] from
Actor[akka://ClusterSystem/system/sharding/Counter#1791785555] to
Actor[akka://ClusterSystem/system/sharding/CounterCoordinator/singleton/coordinator]
was not delivered. [1] dead letters encountered. This logging can be turned
off or adjusted with configuration settings 'akka.log-dead-letters' and
'akka.log-dead-letters-during-shutdown'.
[INFO] [11/11/2015 21:53:23.147]
[ClusterSystem-akka.actor.default-dispatcher-15]
[akka://ClusterSystem/system/sharding/SupervisedCounterCoordinator/singleton/coordinator]
Message [akka.cluster.sharding.ShardCoordinator$Internal$Register] from
Actor[akka://ClusterSystem/system/sharding/SupervisedCounter#-836215563] to
Actor[akka://ClusterSystem/system/sharding/SupervisedCounterCoordinator/singleton/coordinator]
was not delivered. [2] dead letters encountered. This logging can be turned
off or adjusted with configuration settings 'akka.log-dead-letters' and
'akka.log-dead-letters-during-shutdown'.
SLF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder".
SLF4J: Defaulting to no-operation (NOP) logger implementation
SLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further
details.
updating ###################
updating ###################
[ERROR] [11/11/2015 21:53:26.236]
[ClusterSystem-akka.actor.default-dispatcher-16]
[akka://ClusterSystem/system/sharding/Counter/23/123] Intentional Error
@@@@@@@@@@@@@@@@@@@@@@@@
java.lang.RuntimeException: Intentional Error @@@@@@@@@@@@@@@@@@@@@@@@
at
akka.cluster.sharding.ClusterShardingTest$Counter.updateState(ClusterShardingTest.java:160)
at
akka.cluster.sharding.ClusterShardingTest$Counter$1.apply(ClusterShardingTest.java:181)
at
akka.cluster.sharding.ClusterShardingTest$Counter$1.apply(ClusterShardingTest.java:179)
at
akka.persistence.UntypedPersistentActor$$anonfun$persist$1.apply(PersistentActor.scala:149)
at
akka.persistence.UntypedPersistentActor$$anonfun$persist$1.apply(PersistentActor.scala:149)
at
akka.persistence.Eventsourced$class.akka$persistence$Eventsourced$$peekApplyHandler(Eventsourced.scala:529)
at
akka.persistence.Eventsourced$ProcessingState$$anonfun$2.applyOrElse(Eventsourced.scala:549)
at
scala.runtime.AbstractPartialFunction.apply(AbstractPartialFunction.scala:36)
at
akka.persistence.Eventsourced$$anon$2.stateReceive(Eventsourced.scala:625)
at akka.persistence.Eventsourced$class.aroundReceive(Eventsourced.scala:158)
at
akka.persistence.UntypedPersistentActor.aroundReceive(PersistentActor.scala:111)
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:525)
at akka.actor.ActorCell.invoke(ActorCell.scala:494)
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:257)
at akka.dispatch.Mailbox.run(Mailbox.scala:224)
at akka.dispatch.Mailbox.exec(Mailbox.scala:234)
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
at
scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
at
scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
[ERROR] [11/11/2015 21:53:26.236]
[ClusterSystem-akka.actor.default-dispatcher-22]
[akka://ClusterSystem/system/sharding/Counter/24/124] Intentional Error
@@@@@@@@@@@@@@@@@@@@@@@@
java.lang.RuntimeException: Intentional Error @@@@@@@@@@@@@@@@@@@@@@@@
at
akka.cluster.sharding.ClusterShardingTest$Counter.updateState(ClusterShardingTest.java:160)
at
akka.cluster.sharding.ClusterShardingTest$Counter$1.apply(ClusterShardingTest.java:181)
at
akka.cluster.sharding.ClusterShardingTest$Counter$1.apply(ClusterShardingTest.java:179)
at
akka.persistence.UntypedPersistentActor$$anonfun$persist$1.apply(PersistentActor.scala:149)
at
akka.persistence.UntypedPersistentActor$$anonfun$persist$1.apply(PersistentActor.scala:149)
at
akka.persistence.Eventsourced$class.akka$persistence$Eventsourced$$peekApplyHandler(Eventsourced.scala:529)
at
akka.persistence.Eventsourced$ProcessingState$$anonfun$2.applyOrElse(Eventsourced.scala:549)
at
scala.runtime.AbstractPartialFunction.apply(AbstractPartialFunction.scala:36)
at
akka.persistence.Eventsourced$$anon$2.stateReceive(Eventsourced.scala:625)
at akka.persistence.Eventsourced$class.aroundReceive(Eventsourced.scala:158)
at
akka.persistence.UntypedPersistentActor.aroundReceive(PersistentActor.scala:111)
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:525)
at akka.actor.ActorCell.invoke(ActorCell.scala:494)
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:257)
at akka.dispatch.Mailbox.run(Mailbox.scala:224)
at akka.dispatch.Mailbox.exec(Mailbox.scala:234)
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
at
scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
at
scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
updating ###################
updating ###################
[ERROR] [11/11/2015 21:53:26.261]
[ClusterSystem-akka.actor.default-dispatcher-16]
[akka.tcp://[email protected]:2550/system/sharding/Counter/23/123]
Exception in receiveRecover when replaying event type
[akka.cluster.sharding.ClusterShardingTest$Counter$CounterChanged] with
sequence number [1] for persistenceId [Counter-123].
java.lang.RuntimeException: Intentional Error @@@@@@@@@@@@@@@@@@@@@@@@
at
akka.cluster.sharding.ClusterShardingTest$Counter.updateState(ClusterShardingTest.java:160)
at
akka.cluster.sharding.ClusterShardingTest$Counter.onReceiveRecover(ClusterShardingTest.java:168)
at
akka.persistence.UntypedPersistentActor$$anonfun$receiveRecover$1.applyOrElse(PersistentActor.scala:116)
at
scala.runtime.AbstractPartialFunction.apply(AbstractPartialFunction.scala:36)
at
akka.persistence.Eventsourced$$anon$3$$anonfun$1.applyOrElse(Eventsourced.scala:438)
at akka.actor.Actor$class.aroundReceive(Actor.scala:480)
at
akka.persistence.UntypedPersistentActor.akka$persistence$Eventsourced$$super$aroundReceive(PersistentActor.scala:111)
at
akka.persistence.Eventsourced$$anon$4.stateReceive(Eventsourced.scala:481)
at akka.persistence.Eventsourced$class.aroundReceive(Eventsourced.scala:158)
at
akka.persistence.UntypedPersistentActor.aroundReceive(PersistentActor.scala:111)
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:525)
at akka.actor.ActorCell.invoke(ActorCell.scala:494)
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:257)
at akka.dispatch.Mailbox.run(Mailbox.scala:224)
at akka.dispatch.Mailbox.exec(Mailbox.scala:234)
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
at
scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
at
scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
[ERROR] [11/11/2015 21:53:26.261]
[ClusterSystem-akka.actor.default-dispatcher-29]
[akka.tcp://[email protected]:2550/system/sharding/Counter/24/124]
Exception in receiveRecover when replaying event type
[akka.cluster.sharding.ClusterShardingTest$Counter$CounterChanged] with
sequence number [1] for persistenceId [Counter-124].
java.lang.RuntimeException: Intentional Error @@@@@@@@@@@@@@@@@@@@@@@@
at
akka.cluster.sharding.ClusterShardingTest$Counter.updateState(ClusterShardingTest.java:160)
at
akka.cluster.sharding.ClusterShardingTest$Counter.onReceiveRecover(ClusterShardingTest.java:168)
at
akka.persistence.UntypedPersistentActor$$anonfun$receiveRecover$1.applyOrElse(PersistentActor.scala:116)
at
scala.runtime.AbstractPartialFunction.apply(AbstractPartialFunction.scala:36)
at
akka.persistence.Eventsourced$$anon$3$$anonfun$1.applyOrElse(Eventsourced.scala:438)
at akka.actor.Actor$class.aroundReceive(Actor.scala:480)
at
akka.persistence.UntypedPersistentActor.akka$persistence$Eventsourced$$super$aroundReceive(PersistentActor.scala:111)
at
akka.persistence.Eventsourced$$anon$4.stateReceive(Eventsourced.scala:481)
at akka.persistence.Eventsourced$class.aroundReceive(Eventsourced.scala:158)
at
akka.persistence.UntypedPersistentActor.aroundReceive(PersistentActor.scala:111)
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:525)
at akka.actor.ActorCell.invoke(ActorCell.scala:494)
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:257)
at akka.dispatch.Mailbox.run(Mailbox.scala:224)
at akka.dispatch.Mailbox.exec(Mailbox.scala:234)
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
at
scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
at
scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
[INFO] [11/11/2015 21:53:26.263]
[ClusterSystem-akka.actor.default-dispatcher-21]
[akka://ClusterSystem/system/sharding/Counter/23/123] Message
[akka.persistence.JournalProtocol$WriteMessagesSuccessful$] from
Actor[akka://ClusterSystem/system/cassandra-journal#1254367220] to
Actor[akka://ClusterSystem/system/sharding/Counter/23/123#-1571818075] was
not delivered. [3] dead letters encountered. This logging can be turned off
or adjusted with configuration settings 'akka.log-dead-letters' and
'akka.log-dead-letters-during-shutdown'.
[INFO] [11/11/2015 21:53:26.263]
[ClusterSystem-akka.actor.default-dispatcher-21]
[akka://ClusterSystem/system/sharding/Counter/24/124] Message
[akka.persistence.JournalProtocol$WriteMessagesSuccessful$] from
Actor[akka://ClusterSystem/system/cassandra-journal#1254367220] to
Actor[akka://ClusterSystem/system/sharding/Counter/24/124#-205995186] was
not delivered. [4] dead letters encountered. This logging can be turned off
or adjusted with configuration settings 'akka.log-dead-letters' and
'akka.log-dead-letters-during-shutdown'.
updating ###################
updating ###################
[ERROR] [11/11/2015 21:53:36.300]
[ClusterSystem-akka.actor.default-dispatcher-18]
[akka.tcp://[email protected]:2550/system/sharding/Counter/23/123]
Exception in receiveRecover when replaying event type
[akka.cluster.sharding.ClusterShardingTest$Counter$CounterChanged] with
sequence number [1] for persistenceId [Counter-123].
java.lang.RuntimeException: Intentional Error @@@@@@@@@@@@@@@@@@@@@@@@
at
akka.cluster.sharding.ClusterShardingTest$Counter.updateState(ClusterShardingTest.java:160)
at
akka.cluster.sharding.ClusterShardingTest$Counter.onReceiveRecover(ClusterShardingTest.java:168)
at
akka.persistence.UntypedPersistentActor$$anonfun$receiveRecover$1.applyOrElse(PersistentActor.scala:116)
at
scala.runtime.AbstractPartialFunction.apply(AbstractPartialFunction.scala:36)
at
akka.persistence.Eventsourced$$anon$3$$anonfun$1.applyOrElse(Eventsourced.scala:438)
at akka.actor.Actor$class.aroundReceive(Actor.scala:480)
at
akka.persistence.UntypedPersistentActor.akka$persistence$Eventsourced$$super$aroundReceive(PersistentActor.scala:111)
at
akka.persistence.Eventsourced$$anon$4.stateReceive(Eventsourced.scala:481)
at akka.persistence.Eventsourced$class.aroundReceive(Eventsourced.scala:158)
at
akka.persistence.UntypedPersistentActor.aroundReceive(PersistentActor.scala:111)
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:525)
at akka.actor.ActorCell.invoke(ActorCell.scala:494)
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:257)
at akka.dispatch.Mailbox.run(Mailbox.scala:224)
at akka.dispatch.Mailbox.exec(Mailbox.scala:234)
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
at
scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
at
scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
[ERROR] [11/11/2015 21:53:36.300]
[ClusterSystem-akka.actor.default-dispatcher-32]
[akka.tcp://[email protected]:2550/system/sharding/Counter/24/124]
Exception in receiveRecover when replaying event type
[akka.cluster.sharding.ClusterShardingTest$Counter$CounterChanged] with
sequence number [1] for persistenceId [Counter-124].
java.lang.RuntimeException: Intentional Error @@@@@@@@@@@@@@@@@@@@@@@@
at
akka.cluster.sharding.ClusterShardingTest$Counter.updateState(ClusterShardingTest.java:160)
at
akka.cluster.sharding.ClusterShardingTest$Counter.onReceiveRecover(ClusterShardingTest.java:168)
at
akka.persistence.UntypedPersistentActor$$anonfun$receiveRecover$1.applyOrElse(PersistentActor.scala:116)
at
scala.runtime.AbstractPartialFunction.apply(AbstractPartialFunction.scala:36)
at
akka.persistence.Eventsourced$$anon$3$$anonfun$1.applyOrElse(Eventsourced.scala:438)
at akka.actor.Actor$class.aroundReceive(Actor.scala:480)
at
akka.persistence.UntypedPersistentActor.akka$persistence$Eventsourced$$super$aroundReceive(PersistentActor.scala:111)
at
akka.persistence.Eventsourced$$anon$4.stateReceive(Eventsourced.scala:481)
at akka.persistence.Eventsourced$class.aroundReceive(Eventsourced.scala:158)
at
akka.persistence.UntypedPersistentActor.aroundReceive(PersistentActor.scala:111)
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:525)
at akka.actor.ActorCell.invoke(ActorCell.scala:494)
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:257)
at akka.dispatch.Mailbox.run(Mailbox.scala:224)
at akka.dispatch.Mailbox.exec(Mailbox.scala:234)
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
at
scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
at
scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
Process finished with exit code -1
--
>>>>>>>>>> Read the docs: http://akka.io/docs/
>>>>>>>>>> Check the FAQ:
>>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user
---
You received this message because you are subscribed to the Google Groups "Akka
User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email
to [email protected].
To post to this group, send email to [email protected].
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
