Akka cluster sharding exception propagation to the parent actor
420 views
Skip to first unread message
sd d
Nov 11, 2015, 9:54:17 PM11/11/15
to Akka User List
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.
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://Cluste...@127.0.0.1:2550]
[INFO] [11/11/2015 21:53:21.951] [main] [akka.remote.Remoting] Remoting now listens on addresses: [akka.tcp://Cluste...@127.0.0.1:2550]
[INFO] [11/11/2015 21:53:21.962] [main] [akka.cluster.Cluster(akka://ClusterSystem)] Cluster Node [akka.tcp://Cluste...@127.0.0.1:2550] - Starting up...
[INFO] [11/11/2015 21:53:22.035] [main] [akka.cluster.Cluster(akka://ClusterSystem)] Cluster Node [akka.tcp://Cluste...@127.0.0.1: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://Cluste...@127.0.0.1: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://Cluste...@127.0.0.1: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://Cluste...@127.0.0.1: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://Cluste...@127.0.0.1:2550] - Node [akka.tcp://Cluste...@127.0.0.1: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://Cluste...@127.0.0.1:2550] - Leader is moving node [akka.tcp://Cluste...@127.0.0.1:2550] to [Up]
[INFO] [11/11/2015 21:53:23.146] [ClusterSystem-akka.actor.default-dispatcher-19] [akka.tcp://Cluste...@127.0.0.1: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://Cluste...@127.0.0.1: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://Cluste...@127.0.0.1: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://Cluste...@127.0.0.1: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://Cluste...@127.0.0.1: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://Cluste...@127.0.0.1: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://Cluste...@127.0.0.1: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://Cluste...@127.0.0.1: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
Patrik Nordwall
Nov 16, 2015, 10:01:03 AM11/16/15
to akka...@googlegroups.com
Are those exceptions because you send new messages to the entity actor? Do they stop when you stop sending messages to the actor?
Please read this section of the docs: http://doc.akka.io/docs/akka/2.4.0/scala/persistence.html#Failures
Also, try the BackoffSupervisor. Let me know if you still have problems after that and we will try to sort them out.
Regards,
Patrik
--
>>>>>>>>>> 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 akka-user+...@googlegroups.com.
To post to this group, send email to akka...@googlegroups.com.
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
Patrik Nordwall
Typesafe - Reactive apps on the JVM
Twitter: @patriknw
Владимир Морозов
Jan 28, 2016, 6:17:05 PM1/28/16
to Akka User List
Hi,
понедельник, 16 ноября 2015 г., 18:01:03 UTC+3 пользователь Patrik Nordwall написал:
I have similar problem, my PersistentActor begin restart forever when inside receiveCommand throws some exception. How I can manage that restarts? Creating actor from BackoffSupervisor not help.
Regards,
Vladimir
понедельник, 16 ноября 2015 г., 18:01:03 UTC+3 пользователь Patrik Nordwall написал:
Are those exceptions because you send new messages to the entity actor? Do they stop when you stop sending messages to the actor?BackoffSupervisor only helps for persist failures (database exception) or failures during recovery, i.e. when the actor is stopped. If you throw exception in receiveCommand it will trigger a normal restart, which will trigger a persistent actor replay.Please read this section of the docs: http://doc.akka.io/docs/akka/2.4.0/scala/persistence.html#FailuresAlso, try the BackoffSupervisor. Let me know if you still have problems after that and we will try to sort them out.Regards,Patrik
On Thu, Nov 12, 2015 at 3:54 AM, sd d <dvsf...@gmail.com> wrote:
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.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://ClusterSystem@127.0.0.1:2550][INFO] [11/11/2015 21:53:21.951] [main] [akka.remote.Remoting] Remoting now listens on addresses: [akka.tcp://ClusterSystem@127.0.0.1:2550][INFO] [11/11/2015 21:53:21.962] [main] [akka.cluster.Cluster(akka://ClusterSystem)] Cluster Node [akka.tcp://ClusterSystem@127.0.0.1:2550] - Starting up...[INFO] [11/11/2015 21:53:22.035] [main] [akka.cluster.Cluster(akka://ClusterSystem)] Cluster Node [akka.tcp://ClusterSystem@127.0.0.1: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://ClusterSystem@127.0.0.1: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://ClusterSystem@127.0.0.1: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://ClusterSystem@127.0.0.1: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://ClusterSystem@127.0.0.1:2550] - Node [akka.tcp://ClusterSystem@127.0.0.1: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://ClusterSystem@127.0.0.1:2550] - Leader is moving node [akka.tcp://ClusterSystem@127.0.0.1:2550] to [Up][INFO] [11/11/2015 21:53:23.146] [ClusterSystem-akka.actor.default-dispatcher-19] [akka.tcp://ClusterSystem@127.0.0.1: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://ClusterSystem@127.0.0.1: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://ClusterSystem@127.0.0.1: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://ClusterSystem@127.0.0.1:2550/system/sharding/SupervisedCounterCoordinator] ClusterSingletonManager state change [Start -> Oldest]
[ERROR] [11/11/2015 21:53:26.261] [ClusterSystem-akka.actor.default-dispatcher-16] [akka.tcp://ClusterSystem@127.0.0.1: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://ClusterSystem@127.0.0.1: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)
...
Patrik Nordwall
Jan 29, 2016, 12:36:25 PM1/29/16
to Akka User List
BackoffSupervisor has support for that in Akka 2.4.1
/Patrik
/Patrik
[INFO] [11/11/2015 21:53:21.949] [main] [akka.remote.Remoting] Remoting started; listening on addresses :[akka.tcp://Cluste...@127.0.0.1:2550][INFO] [11/11/2015 21:53:21.951] [main] [akka.remote.Remoting] Remoting now listens on addresses: [akka.tcp://Cluste...@127.0.0.1:2550][INFO] [11/11/2015 21:53:21.962] [main] [akka.cluster.Cluster(akka://ClusterSystem)] Cluster Node [akka.tcp://Cluste...@127.0.0.1:2550] - Starting up...[INFO] [11/11/2015 21:53:22.035] [main] [akka.cluster.Cluster(akka://ClusterSystem)] Cluster Node [akka.tcp://Cluste...@127.0.0.1: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://Cluste...@127.0.0.1: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://Cluste...@127.0.0.1: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://Cluste...@127.0.0.1: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://Cluste...@127.0.0.1:2550] - Node [akka.tcp://Cluste...@127.0.0.1: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://Cluste...@127.0.0.1:2550] - Leader is moving node [akka.tcp://Cluste...@127.0.0.1:2550] to [Up][INFO] [11/11/2015 21:53:23.146] [ClusterSystem-akka.actor.default-dispatcher-19] [akka.tcp://Cluste...@127.0.0.1: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://Cluste...@127.0.0.1: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://Cluste...@127.0.0.1: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://Cluste...@127.0.0.1:2550/system/sharding/SupervisedCounterCoordinator] ClusterSingletonManager state change [Start -> Oldest]
[ERROR] [11/11/2015 21:53:26.261] [ClusterSystem-akka.actor.default-dispatcher-16] [akka.tcp://Cluste...@127.0.0.1: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://Cluste...@127.0.0.1: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)
--...
>>>>>>>>>> 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 akka-user+...@googlegroups.com.
To post to this group, send email to akka...@googlegroups.com.
Visit this group at https://groups.google.com/group/akka-user.
Владимир Морозов
Feb 1, 2016, 2:09:33 AM2/1/16
to Akka User List
I found only one solution, to prevent child restart without any backoff - start use BackoffSupervisor with custom SupervisorStrategy
OneForOneStrategy(
maxNrOfRetries = 1,
withinTimeRange = 1 minute
) {
case NonFatal(ex) =>
Stop
}
пятница, 29 января 2016 г., 20:36:25 UTC+3 пользователь Patrik Nordwall написал:
[INFO] [11/11/2015 21:53:21.949] [main] [akka.remote.Remoting] Remoting started; listening on addresses :[akka.tcp://ClusterSystem@127.0.0.1:2550][INFO] [11/11/2015 21:53:21.951] [main] [akka.remote.Remoting] Remoting now listens on addresses: [akka.tcp://ClusterSystem@127.0.0.1:2550][INFO] [11/11/2015 21:53:21.962] [main] [akka.cluster.Cluster(akka://ClusterSystem)] Cluster Node [akka.tcp://ClusterSystem@127.0.0.1:2550] - Starting up...[INFO] [11/11/2015 21:53:22.035] [main] [akka.cluster.Cluster(akka://ClusterSystem)] Cluster Node [akka.tcp://ClusterSystem@127.0.0.1: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://ClusterSystem@127.0.0.1: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://ClusterSystem@127.0.0.1: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://ClusterSystem@127.0.0.1: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://ClusterSystem@127.0.0.1:2550] - Node [akka.tcp://ClusterSystem@127.0.0.1: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://ClusterSystem@127.0.0.1:2550] - Leader is moving node [akka.tcp://ClusterSystem@127.0.0.1:2550] to [Up][INFO] [11/11/2015 21:53:23.146] [ClusterSystem-akka.actor.default-dispatcher-19] [akka.tcp://ClusterSystem@127.0.0.1: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://ClusterSystem@127.0.0.1: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://ClusterSystem@127.0.0.1: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://ClusterSystem@127.0.0.1:2550/system/sharding/SupervisedCounterCoordinator] ClusterSingletonManager state change [Start -> Oldest]
[ERROR] [11/11/2015 21:53:26.261] [ClusterSystem-akka.actor.default-dispatcher-16] [akka.tcp://ClusterSystem@127.0.0.1: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://
...
Patrik Nordwall
Feb 1, 2016, 6:04:53 AM2/1/16
to akka...@googlegroups.com
Yes, that was what I was thinking about. You could also use the pre-packaged SupervisorStrategy.stoppingStrategy
[INFO] [11/11/2015 21:53:21.949] [main] [akka.remote.Remoting] Remoting started; listening on addresses :[akka.tcp://Cluste...@127.0.0.1:2550][INFO] [11/11/2015 21:53:21.951] [main] [akka.remote.Remoting] Remoting now listens on addresses: [akka.tcp://Cluste...@127.0.0.1:2550][INFO] [11/11/2015 21:53:21.962] [main] [akka.cluster.Cluster(akka://ClusterSystem)] Cluster Node [akka.tcp://Cluste...@127.0.0.1:2550] - Starting up...[INFO] [11/11/2015 21:53:22.035] [main] [akka.cluster.Cluster(akka://ClusterSystem)] Cluster Node [akka.tcp://Cluste...@127.0.0.1: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://Cluste...@127.0.0.1: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://Cluste...@127.0.0.1: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://Cluste...@127.0.0.1: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://Cluste...@127.0.0.1:2550] - Node [akka.tcp://Cluste...@127.0.0.1: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://Cluste...@127.0.0.1:2550] - Leader is moving node [akka.tcp://Cluste...@127.0.0.1:2550] to [Up][INFO] [11/11/2015 21:53:23.146] [ClusterSystem-akka.actor.default-dispatcher-19] [akka.tcp://Cluste...@127.0.0.1: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://Cluste...@127.0.0.1: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://Cluste...@127.0.0.1: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://Cluste...@127.0.0.1:2550/system/sharding/SupervisedCounterCoordinator] ClusterSingletonManager state change [Start -> Oldest]
[ERROR] [11/11/2015 21:53:26.261] [ClusterSystem-akka.actor.default-dispatcher-16] [akka.tcp://Cluste...@127.0.0.1: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://
...--
>>>>>>>>>> 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 akka-user+...@googlegroups.com.
To post to this group, send email to akka...@googlegroups.com.
Visit this group at https://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
Reply all
Reply to author
Forward
0 new messages