[JBoss JIRA] (ISPN-2784) ReplStateTransferCacheLoaderTest fails randomly in FileCacheStore.start()
by Dan Berindei (JIRA)
[ https://issues.jboss.org/browse/ISPN-2784?page=com.atlassian.jira.plugin.... ]
Dan Berindei updated ISPN-2784:
-------------------------------
Status: Resolved (was: Pull Request Sent)
Resolution: Done
> ReplStateTransferCacheLoaderTest fails randomly in FileCacheStore.start()
> -------------------------------------------------------------------------
>
> Key: ISPN-2784
> URL: https://issues.jboss.org/browse/ISPN-2784
> Project: Infinispan
> Issue Type: Bug
> Components: Test Suite
> Affects Versions: 5.2.0.Final
> Reporter: Adrian Nistor
> Assignee: Adrian Nistor
> Fix For: 5.2.1, 5.3.0.Final
>
>
> {noformat}
> Failed
> org.infinispan.statetransfer.ReplStateTransferCacheLoaderTest.createBeforeMethod (from TestSuite)
> Failing for the past 5 builds (Since Unstable#1028 )
> Took 0.22 sec.
> Error Message
> Unable to invoke method public void org.infinispan.loaders.CacheLoaderManagerImpl.start() on object of type CacheLoaderManagerImpl
> Stacktrace
> org.infinispan.CacheException: Unable to invoke method public void org.infinispan.loaders.CacheLoaderManagerImpl.start() on object of type CacheLoaderManagerImpl
> at org.infinispan.util.ReflectionUtil.invokeAccessibly(ReflectionUtil.java:205)
> at org.infinispan.factories.AbstractComponentRegistry$PrioritizedMethod.invoke(AbstractComponentRegistry.java:883)
> at org.infinispan.factories.AbstractComponentRegistry.invokeStartMethods(AbstractComponentRegistry.java:654)
> at org.infinispan.factories.AbstractComponentRegistry.internalStart(AbstractComponentRegistry.java:643)
> at org.infinispan.factories.AbstractComponentRegistry.start(AbstractComponentRegistry.java:546)
> at org.infinispan.factories.ComponentRegistry.start(ComponentRegistry.java:199)
> at org.infinispan.CacheImpl.start(CacheImpl.java:559)
> at org.infinispan.manager.DefaultCacheManager.wireAndStartCache(DefaultCacheManager.java:686)
> at org.infinispan.manager.DefaultCacheManager.createCache(DefaultCacheManager.java:649)
> at org.infinispan.manager.DefaultCacheManager.getCache(DefaultCacheManager.java:545)
> at org.infinispan.manager.DefaultCacheManager.getCache(DefaultCacheManager.java:518)
> at org.infinispan.test.MultipleCacheManagersTest.getCaches(MultipleCacheManagersTest.java:283)
> at org.infinispan.test.MultipleCacheManagersTest.waitForClusterToForm(MultipleCacheManagersTest.java:292)
> at org.infinispan.test.MultipleCacheManagersTest.waitForClusterToForm(MultipleCacheManagersTest.java:301)
> at org.infinispan.statetransfer.ReplStateTransferCacheLoaderTest.createCacheManagers(ReplStateTransferCacheLoaderTest.java:80)
> at org.infinispan.test.MultipleCacheManagersTest.callCreateCacheManagers(MultipleCacheManagersTest.java:91)
> at org.infinispan.test.MultipleCacheManagersTest.createBeforeMethod(MultipleCacheManagersTest.java:101)
> at sun.reflect.GeneratedMethodAccessor163.invoke(Unknown Source)
> at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
> at java.lang.reflect.Method.invoke(Method.java:597)
> at org.testng.internal.MethodInvocationHelper.invokeMethod(MethodInvocationHelper.java:80)
> at org.testng.internal.Invoker.invokeConfigurationMethod(Invoker.java:564)
> at org.testng.internal.Invoker.invokeConfigurations(Invoker.java:213)
> at org.testng.internal.Invoker.invokeMethod(Invoker.java:653)
> at org.testng.internal.Invoker.invokeTestMethod(Invoker.java:901)
> at org.testng.internal.Invoker.invokeTestMethods(Invoker.java:1231)
> at org.testng.internal.TestMethodWorker.invokeTestMethods(TestMethodWorker.java:127)
> at org.testng.internal.TestMethodWorker.run(TestMethodWorker.java:111)
> at org.testng.TestRunner.privateRun(TestRunner.java:767)
> at org.testng.TestRunner.run(TestRunner.java:617)
> at org.testng.SuiteRunner.runTest(SuiteRunner.java:334)
> at org.testng.SuiteRunner.access$000(SuiteRunner.java:37)
> at org.testng.SuiteRunner$SuiteWorker.run(SuiteRunner.java:368)
> at org.testng.internal.thread.ThreadUtil$2.call(ThreadUtil.java:64)
> at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
> at java.util.concurrent.FutureTask.run(FutureTask.java:138)
> at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
> at java.lang.Thread.run(Thread.java:662)
> Caused by: org.infinispan.CacheException: Unable to start cache loaders
> at org.infinispan.loaders.CacheLoaderManagerImpl.start(CacheLoaderManagerImpl.java:160)
> at sun.reflect.GeneratedMethodAccessor86.invoke(Unknown Source)
> at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
> at java.lang.reflect.Method.invoke(Method.java:597)
> at org.infinispan.util.ReflectionUtil.invokeAccessibly(ReflectionUtil.java:203)
> ... 38 more
> Caused by: org.infinispan.config.ConfigurationException: Directory /scratch/jenkins/workspace/Infinispan-master-JDK6-tcp/core/./target/tmp/store_0/___defaultcache does not exist and cannot be created!
> at org.infinispan.loaders.file.FileCacheStore.start(FileCacheStore.java:369)
> at org.infinispan.loaders.CacheLoaderManagerImpl.start(CacheLoaderManagerImpl.java:152)
> ... 42 more
> Standard Output
> 2013-01-31 13:38:18,555 ERROR [ReplStateTransferCacheLoaderTest] (testng-ReplStateTransferCacheLoaderTest) Error in test setup:
> org.infinispan.CacheException: Unable to invoke method public void org.infinispan.loaders.CacheLoaderManagerImpl.start() on object of type CacheLoaderManagerImpl
> at org.infinispan.util.ReflectionUtil.invokeAccessibly(ReflectionUtil.java:205)
> at org.infinispan.factories.AbstractComponentRegistry$PrioritizedMethod.invoke(AbstractComponentRegistry.java:883)
> at org.infinispan.factories.AbstractComponentRegistry.invokeStartMethods(AbstractComponentRegistry.java:654)
> at org.infinispan.factories.AbstractComponentRegistry.internalStart(AbstractComponentRegistry.java:643)
> at org.infinispan.factories.AbstractComponentRegistry.start(AbstractComponentRegistry.java:546)
> at org.infinispan.factories.ComponentRegistry.start(ComponentRegistry.java:199)
> at org.infinispan.CacheImpl.start(CacheImpl.java:559)
> at org.infinispan.manager.DefaultCacheManager.wireAndStartCache(DefaultCacheManager.java:686)
> at org.infinispan.manager.DefaultCacheManager.createCache(DefaultCacheManager.java:649)
> at org.infinispan.manager.DefaultCacheManager.getCache(DefaultCacheManager.java:545)
> at org.infinispan.manager.DefaultCacheManager.getCache(DefaultCacheManager.java:518)
> at org.infinispan.test.MultipleCacheManagersTest.getCaches(MultipleCacheManagersTest.java:283)
> at org.infinispan.test.MultipleCacheManagersTest.waitForClusterToForm(MultipleCacheManagersTest.java:292)
> at org.infinispan.test.MultipleCacheManagersTest.waitForClusterToForm(MultipleCacheManagersTest.java:301)
> at org.infinispan.statetransfer.ReplStateTransferCacheLoaderTest.createCacheManagers(ReplStateTransferCacheLoaderTest.java:80)
> at org.infinispan.test.MultipleCacheManagersTest.callCreateCacheManagers(MultipleCacheManagersTest.java:91)
> at org.infinispan.test.MultipleCacheManagersTest.createBeforeMethod(MultipleCacheManagersTest.java:101)
> at sun.reflect.GeneratedMethodAccessor163.invoke(Unknown Source)
> at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
> at java.lang.reflect.Method.invoke(Method.java:597)
> at org.testng.internal.MethodInvocationHelper.invokeMethod(MethodInvocationHelper.java:80)
> at org.testng.internal.Invoker.invokeConfigurationMethod(Invoker.java:564)
> at org.testng.internal.Invoker.invokeConfigurations(Invoker.java:213)
> at org.testng.internal.Invoker.invokeMethod(Invoker.java:653)
> at org.testng.internal.Invoker.invokeTestMethod(Invoker.java:901)
> at org.testng.internal.Invoker.invokeTestMethods(Invoker.java:1231)
> at org.testng.internal.TestMethodWorker.invokeTestMethods(TestMethodWorker.java:127)
> at org.testng.internal.TestMethodWorker.run(TestMethodWorker.java:111)
> at org.testng.TestRunner.privateRun(TestRunner.java:767)
> at org.testng.TestRunner.run(TestRunner.java:617)
> at org.testng.SuiteRunner.runTest(SuiteRunner.java:334)
> at org.testng.SuiteRunner.access$000(SuiteRunner.java:37)
> at org.testng.SuiteRunner$SuiteWorker.run(SuiteRunner.java:368)
> at org.testng.internal.thread.ThreadUtil$2.call(ThreadUtil.java:64)
> at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
> at java.util.concurrent.FutureTask.run(FutureTask.java:138)
> at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
> at java.lang.Thread.run(Thread.java:662)
> Caused by: org.infinispan.CacheException: Unable to start cache loaders
> at org.infinispan.loaders.CacheLoaderManagerImpl.start(CacheLoaderManagerImpl.java:160)
> at sun.reflect.GeneratedMethodAccessor86.invoke(Unknown Source)
> at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
> at java.lang.reflect.Method.invoke(Method.java:597)
> at org.infinispan.util.ReflectionUtil.invokeAccessibly(ReflectionUtil.java:203)
> ... 38 more
> Caused by: org.infinispan.config.ConfigurationException: Directory /scratch/jenkins/workspace/Infinispan-master-JDK6-tcp/core/./target/tmp/store_0/___defaultcache does not exist and cannot be created!
> at org.infinispan.loaders.file.FileCacheStore.start(FileCacheStore.java:369)
> at org.infinispan.loaders.CacheLoaderManagerImpl.start(CacheLoaderManagerImpl.java:152)
> ... 42 more
>
> {noformat}
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira
11 years, 2 months
[JBoss JIRA] (ISPN-2787) NPE after ReplaceCommand
by Michal Linhard (JIRA)
[ https://issues.jboss.org/browse/ISPN-2787?page=com.atlassian.jira.plugin.... ]
Michal Linhard commented on ISPN-2787:
--------------------------------------
The client stress test that this appeared in was actually JDG 6.1.0.ER10 with patch for ISPN-2776 (changed only MIMECacheEntry class)
but this is about the problem with replaceInternal return type being boolean, which doesn't correspond to possible return values of ReplaceCommand.perform (possibly any object and also null) - second possible exception here is ClassCastException.
> NPE after ReplaceCommand
> ------------------------
>
> Key: ISPN-2787
> URL: https://issues.jboss.org/browse/ISPN-2787
> Project: Infinispan
> Issue Type: Bug
> Affects Versions: 5.2.0.Final
> Reporter: Michal Linhard
> Assignee: Mircea Markus
>
> (from https://jenkins.mw.lab.eng.bos.redhat.com/hudson/view/EDG6/view/EDG-REPOR...)
> {code}
> 05:11:10,804 ERROR [org.apache.catalina.core.ContainerBase.[jboss.web].[default-host].[/].[Resteasy]] (http-/172.18.1.7:8080-15) Servlet.service() for servlet Resteasy threw exception: org.jboss.resteasy.spi.UnhandledException: java.lang.NullPointerException
> at org.jboss.resteasy.core.SynchronousDispatcher.handleApplicationException(SynchronousDispatcher.java:351) [resteasy-jaxrs-2.3.4.Final-redhat-2.jar:2.3.4.Final-redhat-2]
> at org.jboss.resteasy.core.SynchronousDispatcher.handleException(SynchronousDispatcher.java:220) [resteasy-jaxrs-2.3.4.Final-redhat-2.jar:2.3.4.Final-redhat-2]
> at org.jboss.resteasy.core.SynchronousDispatcher.handleInvokerException(SynchronousDispatcher.java:196) [resteasy-jaxrs-2.3.4.Final-redhat-2.jar:2.3.4.Final-redhat-2]
> at org.jboss.resteasy.core.SynchronousDispatcher.getResponse(SynchronousDispatcher.java:551) [resteasy-jaxrs-2.3.4.Final-redhat-2.jar:2.3.4.Final-redhat-2]
> at org.jboss.resteasy.core.SynchronousDispatcher.invoke(SynchronousDispatcher.java:513) [resteasy-jaxrs-2.3.4.Final-redhat-2.jar:2.3.4.Final-redhat-2]
> at org.jboss.resteasy.core.SynchronousDispatcher.invoke(SynchronousDispatcher.java:125) [resteasy-jaxrs-2.3.4.Final-redhat-2.jar:2.3.4.Final-redhat-2]
> at org.jboss.resteasy.plugins.server.servlet.ServletContainerDispatcher.service(ServletContainerDispatcher.java:208) [resteasy-jaxrs-2.3.4.Final-redhat-2.jar:2.3.4.Final-redhat-2]
> at org.jboss.resteasy.plugins.server.servlet.HttpServletDispatcher.service(HttpServletDispatcher.java:55) [resteasy-jaxrs-2.3.4.Final-redhat-2.jar:2.3.4.Final-redhat-2]
> at org.jboss.resteasy.plugins.server.servlet.HttpServletDispatcher.service(HttpServletDispatcher.java:50) [resteasy-jaxrs-2.3.4.Final-redhat-2.jar:2.3.4.Final-redhat-2]
> at javax.servlet.http.HttpServlet.service(HttpServlet.java:847) [jboss-servlet-api_3.0_spec-1.0.1.Final-redhat-2.jar:1.0.1.Final-redhat-2]
> at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:329) [jbossweb-7.0.17.Final-redhat-1.jar:]
> at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:248) [jbossweb-7.0.17.Final-redhat-1.jar:]
> at org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:275) [jbossweb-7.0.17.Final-redhat-1.jar:]
> at org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:161) [jbossweb-7.0.17.Final-redhat-1.jar:]
> at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:155) [jbossweb-7.0.17.Final-redhat-1.jar:]
> at org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:102) [jbossweb-7.0.17.Final-redhat-1.jar:]
> at org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:109) [jbossweb-7.0.17.Final-redhat-1.jar:]
> at org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:372) [jbossweb-7.0.17.Final-redhat-1.jar:]
> at org.apache.coyote.http11.Http11Processor.process(Http11Processor.java:877) [jbossweb-7.0.17.Final-redhat-1.jar:]
> at org.apache.coyote.http11.Http11Protocol$Http11ConnectionHandler.process(Http11Protocol.java:679) [jbossweb-7.0.17.Final-redhat-1.jar:]
> at org.apache.tomcat.util.net.JIoEndpoint$Worker.run(JIoEndpoint.java:931) [jbossweb-7.0.17.Final-redhat-1.jar:]
> at java.lang.Thread.run(Thread.java:662) [rt.jar:1.6.0_38]
> Caused by: java.lang.NullPointerException
> at org.infinispan.CacheImpl.replaceInternal(CacheImpl.java:828) [infinispan-core-5.2.0.CR3-redhat-1.jar:5.2.0.CR3-redhat-1]
> at org.infinispan.CacheImpl.replace(CacheImpl.java:822) [infinispan-core-5.2.0.CR3-redhat-1.jar:5.2.0.CR3-redhat-1]
> at org.infinispan.CacheImpl.replace(CacheImpl.java:817) [infinispan-core-5.2.0.CR3-redhat-1.jar:5.2.0.CR3-redhat-1]
> at org.infinispan.AbstractDelegatingCache.replace(AbstractDelegatingCache.java:153) [infinispan-core-5.2.0.CR3-redhat-1.jar:5.2.0.CR3-redhat-1]
> at org.infinispan.rest.Server.putOrReplace(Server.scala:186) [infinispan-server-rest-5.2.0.CR3-redhat-1-classes.jar:]
> at org.infinispan.rest.Server.org$infinispan$rest$Server$$putInCache(Server.scala:157) [infinispan-server-rest-5.2.0.CR3-redhat-1-classes.jar:]
> at org.infinispan.rest.Server$$anonfun$putEntry$1.apply(Server.scala:133) [infinispan-server-rest-5.2.0.CR3-redhat-1-classes.jar:]
> at org.infinispan.rest.Server$$anonfun$putEntry$1.apply(Server.scala:120) [infinispan-server-rest-5.2.0.CR3-redhat-1-classes.jar:]
> at org.infinispan.rest.Server.protectCacheNotFound(Server.scala:254) [infinispan-server-rest-5.2.0.CR3-redhat-1-classes.jar:]
> at org.infinispan.rest.Server.putEntry(Server.scala:120) [infinispan-server-rest-5.2.0.CR3-redhat-1-classes.jar:]
> at sun.reflect.GeneratedMethodAccessor12.invoke(Unknown Source) [:1.6.0_38]
> at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25) [rt.jar:1.6.0_38]
> at java.lang.reflect.Method.invoke(Method.java:597) [rt.jar:1.6.0_38]
> at org.jboss.resteasy.core.MethodInjectorImpl.invoke(MethodInjectorImpl.java:167) [resteasy-jaxrs-2.3.4.Final-redhat-2.jar:2.3.4.Final-redhat-2]
> at org.jboss.resteasy.core.ResourceMethod.invokeOnTarget(ResourceMethod.java:257) [resteasy-jaxrs-2.3.4.Final-redhat-2.jar:2.3.4.Final-redhat-2]
> at org.jboss.resteasy.core.ResourceMethod.invoke(ResourceMethod.java:222) [resteasy-jaxrs-2.3.4.Final-redhat-2.jar:2.3.4.Final-redhat-2]
> at org.jboss.resteasy.core.ResourceMethod.invoke(ResourceMethod.java:211) [resteasy-jaxrs-2.3.4.Final-redhat-2.jar:2.3.4.Final-redhat-2]
> at org.jboss.resteasy.core.SynchronousDispatcher.getResponse(SynchronousDispatcher.java:536) [resteasy-jaxrs-2.3.4.Final-redhat-2.jar:2.3.4.Final-redhat-2]
> ... 18 more
> {code}
> Seems like the NPE is caused by ReplaceCommand.perform returning null:
> https://github.com/infinispan/infinispan/blob/5.2.0.Final/core/src/main/j...
> Made possible here:
> https://github.com/infinispan/infinispan/blob/5.2.0.Final/core/src/main/j...
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira
11 years, 2 months
[JBoss JIRA] (ISPN-2787) NPE after ReplaceCommand
by Michal Linhard (JIRA)
Michal Linhard created ISPN-2787:
------------------------------------
Summary: NPE after ReplaceCommand
Key: ISPN-2787
URL: https://issues.jboss.org/browse/ISPN-2787
Project: Infinispan
Issue Type: Bug
Affects Versions: 5.2.0.Final
Reporter: Michal Linhard
Assignee: Mircea Markus
(from https://jenkins.mw.lab.eng.bos.redhat.com/hudson/view/EDG6/view/EDG-REPOR...)
{code}
05:11:10,804 ERROR [org.apache.catalina.core.ContainerBase.[jboss.web].[default-host].[/].[Resteasy]] (http-/172.18.1.7:8080-15) Servlet.service() for servlet Resteasy threw exception: org.jboss.resteasy.spi.UnhandledException: java.lang.NullPointerException
at org.jboss.resteasy.core.SynchronousDispatcher.handleApplicationException(SynchronousDispatcher.java:351) [resteasy-jaxrs-2.3.4.Final-redhat-2.jar:2.3.4.Final-redhat-2]
at org.jboss.resteasy.core.SynchronousDispatcher.handleException(SynchronousDispatcher.java:220) [resteasy-jaxrs-2.3.4.Final-redhat-2.jar:2.3.4.Final-redhat-2]
at org.jboss.resteasy.core.SynchronousDispatcher.handleInvokerException(SynchronousDispatcher.java:196) [resteasy-jaxrs-2.3.4.Final-redhat-2.jar:2.3.4.Final-redhat-2]
at org.jboss.resteasy.core.SynchronousDispatcher.getResponse(SynchronousDispatcher.java:551) [resteasy-jaxrs-2.3.4.Final-redhat-2.jar:2.3.4.Final-redhat-2]
at org.jboss.resteasy.core.SynchronousDispatcher.invoke(SynchronousDispatcher.java:513) [resteasy-jaxrs-2.3.4.Final-redhat-2.jar:2.3.4.Final-redhat-2]
at org.jboss.resteasy.core.SynchronousDispatcher.invoke(SynchronousDispatcher.java:125) [resteasy-jaxrs-2.3.4.Final-redhat-2.jar:2.3.4.Final-redhat-2]
at org.jboss.resteasy.plugins.server.servlet.ServletContainerDispatcher.service(ServletContainerDispatcher.java:208) [resteasy-jaxrs-2.3.4.Final-redhat-2.jar:2.3.4.Final-redhat-2]
at org.jboss.resteasy.plugins.server.servlet.HttpServletDispatcher.service(HttpServletDispatcher.java:55) [resteasy-jaxrs-2.3.4.Final-redhat-2.jar:2.3.4.Final-redhat-2]
at org.jboss.resteasy.plugins.server.servlet.HttpServletDispatcher.service(HttpServletDispatcher.java:50) [resteasy-jaxrs-2.3.4.Final-redhat-2.jar:2.3.4.Final-redhat-2]
at javax.servlet.http.HttpServlet.service(HttpServlet.java:847) [jboss-servlet-api_3.0_spec-1.0.1.Final-redhat-2.jar:1.0.1.Final-redhat-2]
at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:329) [jbossweb-7.0.17.Final-redhat-1.jar:]
at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:248) [jbossweb-7.0.17.Final-redhat-1.jar:]
at org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:275) [jbossweb-7.0.17.Final-redhat-1.jar:]
at org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:161) [jbossweb-7.0.17.Final-redhat-1.jar:]
at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:155) [jbossweb-7.0.17.Final-redhat-1.jar:]
at org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:102) [jbossweb-7.0.17.Final-redhat-1.jar:]
at org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:109) [jbossweb-7.0.17.Final-redhat-1.jar:]
at org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:372) [jbossweb-7.0.17.Final-redhat-1.jar:]
at org.apache.coyote.http11.Http11Processor.process(Http11Processor.java:877) [jbossweb-7.0.17.Final-redhat-1.jar:]
at org.apache.coyote.http11.Http11Protocol$Http11ConnectionHandler.process(Http11Protocol.java:679) [jbossweb-7.0.17.Final-redhat-1.jar:]
at org.apache.tomcat.util.net.JIoEndpoint$Worker.run(JIoEndpoint.java:931) [jbossweb-7.0.17.Final-redhat-1.jar:]
at java.lang.Thread.run(Thread.java:662) [rt.jar:1.6.0_38]
Caused by: java.lang.NullPointerException
at org.infinispan.CacheImpl.replaceInternal(CacheImpl.java:828) [infinispan-core-5.2.0.CR3-redhat-1.jar:5.2.0.CR3-redhat-1]
at org.infinispan.CacheImpl.replace(CacheImpl.java:822) [infinispan-core-5.2.0.CR3-redhat-1.jar:5.2.0.CR3-redhat-1]
at org.infinispan.CacheImpl.replace(CacheImpl.java:817) [infinispan-core-5.2.0.CR3-redhat-1.jar:5.2.0.CR3-redhat-1]
at org.infinispan.AbstractDelegatingCache.replace(AbstractDelegatingCache.java:153) [infinispan-core-5.2.0.CR3-redhat-1.jar:5.2.0.CR3-redhat-1]
at org.infinispan.rest.Server.putOrReplace(Server.scala:186) [infinispan-server-rest-5.2.0.CR3-redhat-1-classes.jar:]
at org.infinispan.rest.Server.org$infinispan$rest$Server$$putInCache(Server.scala:157) [infinispan-server-rest-5.2.0.CR3-redhat-1-classes.jar:]
at org.infinispan.rest.Server$$anonfun$putEntry$1.apply(Server.scala:133) [infinispan-server-rest-5.2.0.CR3-redhat-1-classes.jar:]
at org.infinispan.rest.Server$$anonfun$putEntry$1.apply(Server.scala:120) [infinispan-server-rest-5.2.0.CR3-redhat-1-classes.jar:]
at org.infinispan.rest.Server.protectCacheNotFound(Server.scala:254) [infinispan-server-rest-5.2.0.CR3-redhat-1-classes.jar:]
at org.infinispan.rest.Server.putEntry(Server.scala:120) [infinispan-server-rest-5.2.0.CR3-redhat-1-classes.jar:]
at sun.reflect.GeneratedMethodAccessor12.invoke(Unknown Source) [:1.6.0_38]
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25) [rt.jar:1.6.0_38]
at java.lang.reflect.Method.invoke(Method.java:597) [rt.jar:1.6.0_38]
at org.jboss.resteasy.core.MethodInjectorImpl.invoke(MethodInjectorImpl.java:167) [resteasy-jaxrs-2.3.4.Final-redhat-2.jar:2.3.4.Final-redhat-2]
at org.jboss.resteasy.core.ResourceMethod.invokeOnTarget(ResourceMethod.java:257) [resteasy-jaxrs-2.3.4.Final-redhat-2.jar:2.3.4.Final-redhat-2]
at org.jboss.resteasy.core.ResourceMethod.invoke(ResourceMethod.java:222) [resteasy-jaxrs-2.3.4.Final-redhat-2.jar:2.3.4.Final-redhat-2]
at org.jboss.resteasy.core.ResourceMethod.invoke(ResourceMethod.java:211) [resteasy-jaxrs-2.3.4.Final-redhat-2.jar:2.3.4.Final-redhat-2]
at org.jboss.resteasy.core.SynchronousDispatcher.getResponse(SynchronousDispatcher.java:536) [resteasy-jaxrs-2.3.4.Final-redhat-2.jar:2.3.4.Final-redhat-2]
... 18 more
{code}
Seems like the NPE is caused by ReplaceCommand.perform returning null:
https://github.com/infinispan/infinispan/blob/5.2.0.Final/core/src/main/j...
Made possible here:
https://github.com/infinispan/infinispan/blob/5.2.0.Final/core/src/main/j...
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira
11 years, 2 months
[JBoss JIRA] (ISPN-2427) Test hanging on StateTransferLockImpl.waitForTopology
by Adrian Nistor (JIRA)
[ https://issues.jboss.org/browse/ISPN-2427?page=com.atlassian.jira.plugin.... ]
Adrian Nistor closed ISPN-2427.
-------------------------------
Fix Version/s: 5.3.0.Alpha1
(was: 6.0.0.Final)
Resolution: Out of Date
The thread dump indicates a similar issue to ISPN-2373 but it's not possible to find the exact cause without a trace log. Not reproducible now, so let's close it as out-of-date.
> Test hanging on StateTransferLockImpl.waitForTopology
> -----------------------------------------------------
>
> Key: ISPN-2427
> URL: https://issues.jboss.org/browse/ISPN-2427
> Project: Infinispan
> Issue Type: Bug
> Components: State transfer
> Reporter: Sanne Grinovero
> Assignee: Dan Berindei
> Fix For: 5.3.0.Alpha1
>
> Attachments: lockedStack.txt
>
>
> From a quick glance on the thread dump, I think _OOB-3,Infinispan-Query-Cluster,MultiNodeDistributedTest-NodeA-44306_ is the offender. (not sure!)
> I'm attaching the full dump as a text file.
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira
11 years, 2 months
[JBoss JIRA] (ISPN-2786) ThreadLocal memory leak in Tomcat
by Johann Burkard (JIRA)
Johann Burkard created ISPN-2786:
------------------------------------
Summary: ThreadLocal memory leak in Tomcat
Key: ISPN-2786
URL: https://issues.jboss.org/browse/ISPN-2786
Project: Infinispan
Issue Type: Bug
Components: Marshalling, Transactions
Affects Versions: 5.1.8.Final
Reporter: Johann Burkard
Assignee: Galder Zamarreño
Just started an app using Infinispan 5.1.8.Final on Tomcat and got a few ThreadLocal problems during un-deployment:
(Shortened)
{code}
key=org.jboss.marshalling.UTFUtils.BytesHolder
value=org.jboss.marshalling.UTFUtils$BytesHolder@697a1686
key=java.lang.ThreadLocal@36ed5ba6
value=org.infinispan.context.SingleKeyNonTxInvocationContext{flags=null}
key=org.infinispan.marshall.jboss.AbstractJBossMarshaller$1
value=org.infinispan.marshall.jboss.AbstractJBossMarshaller$1@75f10df7
value=org.infinispan.marshall.jboss.AbstractJBossMarshaller.PerThreadInstanceHolder
{code}
I do call {{DefaultCacheManager#shutdown()}} during un-deployment. :)
Thanks
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira
11 years, 2 months
[JBoss JIRA] (ISPN-2762) Add version information to infinispan-core JAR file
by Alan Field (JIRA)
[ https://issues.jboss.org/browse/ISPN-2762?page=com.atlassian.jira.plugin.... ]
Alan Field commented on ISPN-2762:
----------------------------------
Hey Galder, I wasn't aware of these other ways to get the version from a JAR file, so thanks a lot! I think there are some other Maven plugins that can add the GIT hash, so I'll do some research on that too. Alan
> Add version information to infinispan-core JAR file
> ---------------------------------------------------
>
> Key: ISPN-2762
> URL: https://issues.jboss.org/browse/ISPN-2762
> Project: Infinispan
> Issue Type: Feature Request
> Components: Core API
> Affects Versions: 5.2.0.CR3
> Reporter: Alan Field
> Assignee: Galder Zamarreño
>
> Infinispan version information is logged when a cache is created, but it would be useful to have this information included in the infinispan-core JAR file. I discovered this when I was building and packaging RadarGun and wanted to know which version of Infinispan 5.2 was included. Currently no version information is included in the JAR file.
> The version information for a SNAPSHOT build could include the build date and a git hash, along with the version string.
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira
11 years, 2 months
[JBoss JIRA] (ISPN-2779) Lost data on remotecache get() after put()
by Dan Berindei (JIRA)
[ https://issues.jboss.org/browse/ISPN-2779?page=com.atlassian.jira.plugin.... ]
Dan Berindei updated ISPN-2779:
-------------------------------
Description:
I'm start server Infinispan on Ubuntu follow comand:
{noformat}
./startServer.sh -r hotrod -c infinispan-distribution.xml -l 192.168.23.120 -Djgroups.bind_addr=192.168.23.120
{noformat}
Make sure we can open many file, /etc/security/limits.conf:
* soft nofile 100002
* hard nofile 100002
Here is content of infinispan-distribution.xml:
{code:xml}
<infinispan xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="urn:infinispan:config:5.1 http://www.infinispan.org/schemas/infinispan-config-5.1.xsd"
xmlns="urn:infinispan:config:5.1">
<global>
<transport>
<properties>
<property name="configurationFile" value="jgroups-tcp.xml">
</property></properties>
</transport>
</global>
<default>
<clustering mode="distribution">
<sync />
<hash numOwners="2" />
</clustering>
</default>
<namedCache name="myCache">
<clustering mode="distribution">
<sync />
<hash numOwners="2" />
</clustering>
</namedCache>
<namedCache name="evictionCache">
<clustering mode="distribution">
<sync />
<hash numOwners="2" rehashEnabled="true" rehashRpcTimeout="600000" numVirtualNodes="50"/>
</clustering>
<eviction
maxEntries="10000"
strategy="LRU"
/>
<loaders passivation="true" preload="false">
<loader class="org.infinispan.loaders.file.FileCacheStore" fetchPersistentState="true" purgeOnStartup="false">
<properties>
<property name="location" value="data"/>
</properties>
</loader>
</loaders>
</namedCache>
</infinispan>
{code}
I write a simple program to test benmark of infinispan but i got problem of lost data. I put many key-value but when i retrieve it return null.
Here is my program soucecode:
{code:java}
package vn.vccorp.benmark.infinispan;
import java.io.FileWriter;
import java.io.PrintWriter;
import java.net.URL;
import java.util.ArrayList;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;
import java.util.Map.Entry;
import java.util.Random;
import java.util.UUID;
import java.util.concurrent.Callable;
import java.util.concurrent.Executor;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
import org.infinispan.client.hotrod.RemoteCache;
import org.infinispan.client.hotrod.RemoteCacheManager;
public class Benmark implements Callable<Void> {
private static final int MAX_LENGHT = 20;
private static final int MIN_LENGHT = 8;
private Map<String, String> accs = new LinkedHashMap<String, String>();
private final Random random = new Random(System.currentTimeMillis());
private RemoteCache<String, String> rc;
private boolean getOperator = false;
public Benmark(RemoteCache<String, String> rc, int numAcc) {
generateRandomAccs(numAcc);
this.rc = rc;
}
/**
* @param args
* @throws InterruptedException
*/
public static void main(String[] args) throws InterruptedException {
URL resource = Thread.currentThread().getContextClassLoader()
.getResource("hotrod-client.properties");
RemoteCacheManager rcm = new RemoteCacheManager(resource, true);
RemoteCache<String, String> rc = rcm.getCache("evictionCache");
List<Benmark> bens = new ArrayList<Benmark>();
int numThreads = Runtime.getRuntime().availableProcessors() * 2;
int numAccsPerThread = 5000;
for (int i = 0; i < numThreads; ++i) {
bens.add(new Benmark(rc, numAccsPerThread));
}
long time = testOperator(bens);
System.out.println("finish test Put with "
+ (numThreads * numAccsPerThread) + " records in "
+ (time) + "ns");
for (Benmark benmark : bens) {
benmark.setGetOperator(true);
}
time = testOperator(bens);
System.out.println("finish test Get with "
+ (numThreads * numAccsPerThread) + " records in "
+ (time) + "ns");
rcm.stop();
saveDataTest(bens);
}
private static void saveDataTest(List<Benmark> bens) {
PrintWriter writer = null;
try {
writer = new PrintWriter(new FileWriter("data_test.txt"));
for (Benmark ben : bens) {
for (Entry<String, String> entry : ben.getAccs().entrySet()) {
writer.println(entry.getKey());
writer.println(entry.getValue());
}
}
} catch (Exception e) {
// TODO: handle exception
} finally {
if (writer != null) {
writer.close();
}
}
}
private static long testOperator(List<Benmark> bens) throws InterruptedException {
ExecutorService pool = Executors.newCachedThreadPool();
long time = System.nanoTime();
pool.invokeAll(bens);
pool.shutdown();
while (!pool.awaitTermination(1, TimeUnit.MINUTES)) {
}
long end = System.nanoTime();
return end - time;
}
private void generateRandomAccs(int numberAcc) {
String user = null;
String pass = null;
for (int i = 0; i < numberAcc;) {
user = randomString();
pass = randomString();
if (getAccs().put(user, pass) == null) {
++i;
}
}
}
private String randomString() {
// int len = MIN_LENGHT + random.nextInt(MAX_LENGHT - MIN_LENGHT);
// StringBuilder builder = new StringBuilder(len);
// for (int i = 0; i < len; ++i) {
// char c = (char) (32 + random.nextInt(126 - 32));
// builder.append(c);
// }
// return builder.toString();
return UUID.randomUUID().toString();
}
@Override
public Void call() {
if (!getOperator) {
System.out.println("Start test PUT");
long startPut = System.nanoTime();
for (Entry<String, String> acc : getAccs().entrySet()) {
rc.put(acc.getKey(), acc.getValue());
}
long endPut = System.nanoTime();
System.out
.println("Finish test PUT: " + (endPut - startPut) + "ns");
} else {
System.out.println("Start test GET");
long startGet = System.nanoTime();
for (Entry<String, String> acc : getAccs().entrySet()) {
if (rc.get(acc.getKey()) == null) {
System.err.println("Error get data");
break;
}
}
long endGet = System.nanoTime();
System.out
.println("Finish test GET: " + (endGet - startGet) + "ns");
}
return null;
}
public boolean isGetOperator() {
return getOperator;
}
public void setGetOperator(boolean getOperator) {
this.getOperator = getOperator;
}
public Map<String, String> getAccs() {
return accs;
}
public void setAccs(Map<String, String> accs) {
this.accs = accs;
}
}
{code}
was:
I'm start server Infinispan on Ubuntu follow comand:
{noformat}
./startServer.sh -r hotrod -c infinispan-distribution.xml -l 192.168.23.120 -Djgroups.bind_addr=192.168.23.120
{noformat}
Make sure we can open many file, /etc/security/limits.conf:
* soft nofile 100002
* hard nofile 100002
Here is content of infinispan-distribution.xml:
{noformat}
<infinispan xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="urn:infinispan:config:5.1 http://www.infinispan.org/schemas/infinispan-config-5.1.xsd"
xmlns="urn:infinispan:config:5.1">
<global>
<transport>
<properties>
<property name="configurationFile" value="jgroups-tcp.xml">
</property></properties>
</transport>
</global>
<default>
<clustering mode="distribution">
<sync />
<hash numOwners="2" />
</clustering>
</default>
<namedCache name="myCache">
<clustering mode="distribution">
<sync />
<hash numOwners="2" />
</clustering>
</namedCache>
<namedCache name="evictionCache">
<clustering mode="distribution">
<sync />
<hash numOwners="2" rehashEnabled="true" rehashRpcTimeout="600000" numVirtualNodes="50"/>
</clustering>
<eviction
maxEntries="10000"
strategy="LRU"
/>
<loaders passivation="true" preload="false">
<loader class="org.infinispan.loaders.file.FileCacheStore" fetchPersistentState="true" purgeOnStartup="false">
<properties>
<property name="location" value="data"/>
</properties>
</loader>
</loaders>
</namedCache>
</infinispan>
{noformat}
I write a simple program to test benmark of infinispan but i got problem of lost data. I put many key-value but when i retrieve it return null.
Here is my program soucecode:
{noformat}
package vn.vccorp.benmark.infinispan;
import java.io.FileWriter;
import java.io.PrintWriter;
import java.net.URL;
import java.util.ArrayList;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;
import java.util.Map.Entry;
import java.util.Random;
import java.util.UUID;
import java.util.concurrent.Callable;
import java.util.concurrent.Executor;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
import org.infinispan.client.hotrod.RemoteCache;
import org.infinispan.client.hotrod.RemoteCacheManager;
public class Benmark implements Callable<Void> {
private static final int MAX_LENGHT = 20;
private static final int MIN_LENGHT = 8;
private Map<String, String> accs = new LinkedHashMap<String, String>();
private final Random random = new Random(System.currentTimeMillis());
private RemoteCache<String, String> rc;
private boolean getOperator = false;
public Benmark(RemoteCache<String, String> rc, int numAcc) {
generateRandomAccs(numAcc);
this.rc = rc;
}
/**
* @param args
* @throws InterruptedException
*/
public static void main(String[] args) throws InterruptedException {
URL resource = Thread.currentThread().getContextClassLoader()
.getResource("hotrod-client.properties");
RemoteCacheManager rcm = new RemoteCacheManager(resource, true);
RemoteCache<String, String> rc = rcm.getCache("evictionCache");
List<Benmark> bens = new ArrayList<Benmark>();
int numThreads = Runtime.getRuntime().availableProcessors() * 2;
int numAccsPerThread = 5000;
for (int i = 0; i < numThreads; ++i) {
bens.add(new Benmark(rc, numAccsPerThread));
}
long time = testOperator(bens);
System.out.println("finish test Put with "
+ (numThreads * numAccsPerThread) + " records in "
+ (time) + "ns");
for (Benmark benmark : bens) {
benmark.setGetOperator(true);
}
time = testOperator(bens);
System.out.println("finish test Get with "
+ (numThreads * numAccsPerThread) + " records in "
+ (time) + "ns");
rcm.stop();
saveDataTest(bens);
}
private static void saveDataTest(List<Benmark> bens) {
PrintWriter writer = null;
try {
writer = new PrintWriter(new FileWriter("data_test.txt"));
for (Benmark ben : bens) {
for (Entry<String, String> entry : ben.getAccs().entrySet()) {
writer.println(entry.getKey());
writer.println(entry.getValue());
}
}
} catch (Exception e) {
// TODO: handle exception
} finally {
if (writer != null) {
writer.close();
}
}
}
private static long testOperator(List<Benmark> bens) throws InterruptedException {
ExecutorService pool = Executors.newCachedThreadPool();
long time = System.nanoTime();
pool.invokeAll(bens);
pool.shutdown();
while (!pool.awaitTermination(1, TimeUnit.MINUTES)) {
}
long end = System.nanoTime();
return end - time;
}
private void generateRandomAccs(int numberAcc) {
String user = null;
String pass = null;
for (int i = 0; i < numberAcc;) {
user = randomString();
pass = randomString();
if (getAccs().put(user, pass) == null) {
++i;
}
}
}
private String randomString() {
// int len = MIN_LENGHT + random.nextInt(MAX_LENGHT - MIN_LENGHT);
// StringBuilder builder = new StringBuilder(len);
// for (int i = 0; i < len; ++i) {
// char c = (char) (32 + random.nextInt(126 - 32));
// builder.append(c);
// }
// return builder.toString();
return UUID.randomUUID().toString();
}
@Override
public Void call() {
if (!getOperator) {
System.out.println("Start test PUT");
long startPut = System.nanoTime();
for (Entry<String, String> acc : getAccs().entrySet()) {
rc.put(acc.getKey(), acc.getValue());
}
long endPut = System.nanoTime();
System.out
.println("Finish test PUT: " + (endPut - startPut) + "ns");
} else {
System.out.println("Start test GET");
long startGet = System.nanoTime();
for (Entry<String, String> acc : getAccs().entrySet()) {
if (rc.get(acc.getKey()) == null) {
System.err.println("Error get data");
break;
}
}
long endGet = System.nanoTime();
System.out
.println("Finish test GET: " + (endGet - startGet) + "ns");
}
return null;
}
public boolean isGetOperator() {
return getOperator;
}
public void setGetOperator(boolean getOperator) {
this.getOperator = getOperator;
}
public Map<String, String> getAccs() {
return accs;
}
public void setAccs(Map<String, String> accs) {
this.accs = accs;
}
}
{noformat}
> Lost data on remotecache get() after put()
> ------------------------------------------
>
> Key: ISPN-2779
> URL: https://issues.jboss.org/browse/ISPN-2779
> Project: Infinispan
> Issue Type: Bug
> Components: Distributed Cache, Eviction, Loaders and Stores, Server
> Affects Versions: 5.1.6.FINAL, 5.2.0.CR3
> Environment: Windows 7SP1 Pro
> JDK 7 or JRE6
> Reporter: ThienLong Hong
> Assignee: Tristan Tarrant
>
> I'm start server Infinispan on Ubuntu follow comand:
> {noformat}
> ./startServer.sh -r hotrod -c infinispan-distribution.xml -l 192.168.23.120 -Djgroups.bind_addr=192.168.23.120
> {noformat}
> Make sure we can open many file, /etc/security/limits.conf:
> * soft nofile 100002
> * hard nofile 100002
> Here is content of infinispan-distribution.xml:
> {code:xml}
> <infinispan xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
> xsi:schemaLocation="urn:infinispan:config:5.1 http://www.infinispan.org/schemas/infinispan-config-5.1.xsd"
> xmlns="urn:infinispan:config:5.1">
> <global>
> <transport>
> <properties>
> <property name="configurationFile" value="jgroups-tcp.xml">
> </property></properties>
> </transport>
> </global>
> <default>
> <clustering mode="distribution">
> <sync />
> <hash numOwners="2" />
> </clustering>
> </default>
> <namedCache name="myCache">
> <clustering mode="distribution">
> <sync />
> <hash numOwners="2" />
> </clustering>
> </namedCache>
> <namedCache name="evictionCache">
> <clustering mode="distribution">
> <sync />
> <hash numOwners="2" rehashEnabled="true" rehashRpcTimeout="600000" numVirtualNodes="50"/>
> </clustering>
> <eviction
> maxEntries="10000"
> strategy="LRU"
> />
> <loaders passivation="true" preload="false">
> <loader class="org.infinispan.loaders.file.FileCacheStore" fetchPersistentState="true" purgeOnStartup="false">
> <properties>
> <property name="location" value="data"/>
> </properties>
> </loader>
> </loaders>
> </namedCache>
> </infinispan>
> {code}
> I write a simple program to test benmark of infinispan but i got problem of lost data. I put many key-value but when i retrieve it return null.
> Here is my program soucecode:
> {code:java}
> package vn.vccorp.benmark.infinispan;
> import java.io.FileWriter;
> import java.io.PrintWriter;
> import java.net.URL;
> import java.util.ArrayList;
> import java.util.LinkedHashMap;
> import java.util.List;
> import java.util.Map;
> import java.util.Map.Entry;
> import java.util.Random;
> import java.util.UUID;
> import java.util.concurrent.Callable;
> import java.util.concurrent.Executor;
> import java.util.concurrent.ExecutorService;
> import java.util.concurrent.Executors;
> import java.util.concurrent.TimeUnit;
> import org.infinispan.client.hotrod.RemoteCache;
> import org.infinispan.client.hotrod.RemoteCacheManager;
> public class Benmark implements Callable<Void> {
> private static final int MAX_LENGHT = 20;
> private static final int MIN_LENGHT = 8;
> private Map<String, String> accs = new LinkedHashMap<String, String>();
> private final Random random = new Random(System.currentTimeMillis());
> private RemoteCache<String, String> rc;
> private boolean getOperator = false;
> public Benmark(RemoteCache<String, String> rc, int numAcc) {
> generateRandomAccs(numAcc);
> this.rc = rc;
> }
> /**
> * @param args
> * @throws InterruptedException
> */
> public static void main(String[] args) throws InterruptedException {
> URL resource = Thread.currentThread().getContextClassLoader()
> .getResource("hotrod-client.properties");
> RemoteCacheManager rcm = new RemoteCacheManager(resource, true);
> RemoteCache<String, String> rc = rcm.getCache("evictionCache");
> List<Benmark> bens = new ArrayList<Benmark>();
> int numThreads = Runtime.getRuntime().availableProcessors() * 2;
> int numAccsPerThread = 5000;
> for (int i = 0; i < numThreads; ++i) {
> bens.add(new Benmark(rc, numAccsPerThread));
> }
> long time = testOperator(bens);
> System.out.println("finish test Put with "
> + (numThreads * numAccsPerThread) + " records in "
> + (time) + "ns");
> for (Benmark benmark : bens) {
> benmark.setGetOperator(true);
> }
> time = testOperator(bens);
> System.out.println("finish test Get with "
> + (numThreads * numAccsPerThread) + " records in "
> + (time) + "ns");
> rcm.stop();
> saveDataTest(bens);
> }
> private static void saveDataTest(List<Benmark> bens) {
> PrintWriter writer = null;
> try {
> writer = new PrintWriter(new FileWriter("data_test.txt"));
> for (Benmark ben : bens) {
> for (Entry<String, String> entry : ben.getAccs().entrySet()) {
> writer.println(entry.getKey());
> writer.println(entry.getValue());
> }
> }
> } catch (Exception e) {
> // TODO: handle exception
> } finally {
> if (writer != null) {
> writer.close();
> }
> }
> }
> private static long testOperator(List<Benmark> bens) throws InterruptedException {
> ExecutorService pool = Executors.newCachedThreadPool();
> long time = System.nanoTime();
> pool.invokeAll(bens);
> pool.shutdown();
> while (!pool.awaitTermination(1, TimeUnit.MINUTES)) {
> }
> long end = System.nanoTime();
> return end - time;
> }
> private void generateRandomAccs(int numberAcc) {
> String user = null;
> String pass = null;
> for (int i = 0; i < numberAcc;) {
> user = randomString();
> pass = randomString();
> if (getAccs().put(user, pass) == null) {
> ++i;
> }
> }
> }
> private String randomString() {
> // int len = MIN_LENGHT + random.nextInt(MAX_LENGHT - MIN_LENGHT);
> // StringBuilder builder = new StringBuilder(len);
> // for (int i = 0; i < len; ++i) {
> // char c = (char) (32 + random.nextInt(126 - 32));
> // builder.append(c);
> // }
> // return builder.toString();
> return UUID.randomUUID().toString();
> }
> @Override
> public Void call() {
> if (!getOperator) {
> System.out.println("Start test PUT");
> long startPut = System.nanoTime();
> for (Entry<String, String> acc : getAccs().entrySet()) {
> rc.put(acc.getKey(), acc.getValue());
> }
> long endPut = System.nanoTime();
> System.out
> .println("Finish test PUT: " + (endPut - startPut) + "ns");
> } else {
> System.out.println("Start test GET");
> long startGet = System.nanoTime();
> for (Entry<String, String> acc : getAccs().entrySet()) {
> if (rc.get(acc.getKey()) == null) {
> System.err.println("Error get data");
> break;
> }
> }
> long endGet = System.nanoTime();
> System.out
> .println("Finish test GET: " + (endGet - startGet) + "ns");
> }
> return null;
> }
> public boolean isGetOperator() {
> return getOperator;
> }
> public void setGetOperator(boolean getOperator) {
> this.getOperator = getOperator;
> }
> public Map<String, String> getAccs() {
> return accs;
> }
> public void setAccs(Map<String, String> accs) {
> this.accs = accs;
> }
> }
> {code}
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira
11 years, 2 months
[JBoss JIRA] (ISPN-2779) Lost data on remotecache get() after put()
by Dan Berindei (JIRA)
[ https://issues.jboss.org/browse/ISPN-2779?page=com.atlassian.jira.plugin.... ]
Dan Berindei updated ISPN-2779:
-------------------------------
Description:
I'm start server Infinispan on Ubuntu follow comand:
{noformat}
./startServer.sh -r hotrod -c infinispan-distribution.xml -l 192.168.23.120 -Djgroups.bind_addr=192.168.23.120
{noformat}
Make sure we can open many file, /etc/security/limits.conf:
* soft nofile 100002
* hard nofile 100002
Here is content of infinispan-distribution.xml:
{noformat}
<infinispan xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="urn:infinispan:config:5.1 http://www.infinispan.org/schemas/infinispan-config-5.1.xsd"
xmlns="urn:infinispan:config:5.1">
<global>
<transport>
<properties>
<property name="configurationFile" value="jgroups-tcp.xml">
</property></properties>
</transport>
</global>
<default>
<clustering mode="distribution">
<sync />
<hash numOwners="2" />
</clustering>
</default>
<namedCache name="myCache">
<clustering mode="distribution">
<sync />
<hash numOwners="2" />
</clustering>
</namedCache>
<namedCache name="evictionCache">
<clustering mode="distribution">
<sync />
<hash numOwners="2" rehashEnabled="true" rehashRpcTimeout="600000" numVirtualNodes="50"/>
</clustering>
<eviction
maxEntries="10000"
strategy="LRU"
/>
<loaders passivation="true" preload="false">
<loader class="org.infinispan.loaders.file.FileCacheStore" fetchPersistentState="true" purgeOnStartup="false">
<properties>
<property name="location" value="data"/>
</properties>
</loader>
</loaders>
</namedCache>
</infinispan>
{noformat}
I write a simple program to test benmark of infinispan but i got problem of lost data. I put many key-value but when i retrieve it return null.
Here is my program soucecode:
{noformat}
package vn.vccorp.benmark.infinispan;
import java.io.FileWriter;
import java.io.PrintWriter;
import java.net.URL;
import java.util.ArrayList;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;
import java.util.Map.Entry;
import java.util.Random;
import java.util.UUID;
import java.util.concurrent.Callable;
import java.util.concurrent.Executor;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
import org.infinispan.client.hotrod.RemoteCache;
import org.infinispan.client.hotrod.RemoteCacheManager;
public class Benmark implements Callable<Void> {
private static final int MAX_LENGHT = 20;
private static final int MIN_LENGHT = 8;
private Map<String, String> accs = new LinkedHashMap<String, String>();
private final Random random = new Random(System.currentTimeMillis());
private RemoteCache<String, String> rc;
private boolean getOperator = false;
public Benmark(RemoteCache<String, String> rc, int numAcc) {
generateRandomAccs(numAcc);
this.rc = rc;
}
/**
* @param args
* @throws InterruptedException
*/
public static void main(String[] args) throws InterruptedException {
URL resource = Thread.currentThread().getContextClassLoader()
.getResource("hotrod-client.properties");
RemoteCacheManager rcm = new RemoteCacheManager(resource, true);
RemoteCache<String, String> rc = rcm.getCache("evictionCache");
List<Benmark> bens = new ArrayList<Benmark>();
int numThreads = Runtime.getRuntime().availableProcessors() * 2;
int numAccsPerThread = 5000;
for (int i = 0; i < numThreads; ++i) {
bens.add(new Benmark(rc, numAccsPerThread));
}
long time = testOperator(bens);
System.out.println("finish test Put with "
+ (numThreads * numAccsPerThread) + " records in "
+ (time) + "ns");
for (Benmark benmark : bens) {
benmark.setGetOperator(true);
}
time = testOperator(bens);
System.out.println("finish test Get with "
+ (numThreads * numAccsPerThread) + " records in "
+ (time) + "ns");
rcm.stop();
saveDataTest(bens);
}
private static void saveDataTest(List<Benmark> bens) {
PrintWriter writer = null;
try {
writer = new PrintWriter(new FileWriter("data_test.txt"));
for (Benmark ben : bens) {
for (Entry<String, String> entry : ben.getAccs().entrySet()) {
writer.println(entry.getKey());
writer.println(entry.getValue());
}
}
} catch (Exception e) {
// TODO: handle exception
} finally {
if (writer != null) {
writer.close();
}
}
}
private static long testOperator(List<Benmark> bens) throws InterruptedException {
ExecutorService pool = Executors.newCachedThreadPool();
long time = System.nanoTime();
pool.invokeAll(bens);
pool.shutdown();
while (!pool.awaitTermination(1, TimeUnit.MINUTES)) {
}
long end = System.nanoTime();
return end - time;
}
private void generateRandomAccs(int numberAcc) {
String user = null;
String pass = null;
for (int i = 0; i < numberAcc;) {
user = randomString();
pass = randomString();
if (getAccs().put(user, pass) == null) {
++i;
}
}
}
private String randomString() {
// int len = MIN_LENGHT + random.nextInt(MAX_LENGHT - MIN_LENGHT);
// StringBuilder builder = new StringBuilder(len);
// for (int i = 0; i < len; ++i) {
// char c = (char) (32 + random.nextInt(126 - 32));
// builder.append(c);
// }
// return builder.toString();
return UUID.randomUUID().toString();
}
@Override
public Void call() {
if (!getOperator) {
System.out.println("Start test PUT");
long startPut = System.nanoTime();
for (Entry<String, String> acc : getAccs().entrySet()) {
rc.put(acc.getKey(), acc.getValue());
}
long endPut = System.nanoTime();
System.out
.println("Finish test PUT: " + (endPut - startPut) + "ns");
} else {
System.out.println("Start test GET");
long startGet = System.nanoTime();
for (Entry<String, String> acc : getAccs().entrySet()) {
if (rc.get(acc.getKey()) == null) {
System.err.println("Error get data");
break;
}
}
long endGet = System.nanoTime();
System.out
.println("Finish test GET: " + (endGet - startGet) + "ns");
}
return null;
}
public boolean isGetOperator() {
return getOperator;
}
public void setGetOperator(boolean getOperator) {
this.getOperator = getOperator;
}
public Map<String, String> getAccs() {
return accs;
}
public void setAccs(Map<String, String> accs) {
this.accs = accs;
}
}
{noformat}
was:
I'm start server Infinispan on Ubuntu follow comand:
./startServer.sh -r hotrod -c infinispan-distribution.xml -l 192.168.23.120 -Djgroups.bind_addr=192.168.23.120
Make sure we can open many file, /etc/security/limits.conf:
* soft nofile 100002
* hard nofile 100002
Here is content of infinispan-distribution.xml:
<infinispan xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="urn:infinispan:config:5.1 http://www.infinispan.org/schemas/infinispan-config-5.1.xsd"
xmlns="urn:infinispan:config:5.1">
<global>
<transport>
<properties>
<property name="configurationFile" value="jgroups-tcp.xml">
</property></properties>
</transport>
</global>
<default>
<clustering mode="distribution">
<sync />
<hash numOwners="2" />
</clustering>
</default>
<namedCache name="myCache">
<clustering mode="distribution">
<sync />
<hash numOwners="2" />
</clustering>
</namedCache>
<namedCache name="evictionCache">
<clustering mode="distribution">
<sync />
<hash numOwners="2" rehashEnabled="true" rehashRpcTimeout="600000" numVirtualNodes="50"/>
</clustering>
<eviction
maxEntries="10000"
strategy="LRU"
/>
<loaders passivation="true" preload="false">
<loader class="org.infinispan.loaders.file.FileCacheStore" fetchPersistentState="true" purgeOnStartup="false">
<properties>
<property name="location" value="data"/>
</properties>
</loader>
</loaders>
</namedCache>
</infinispan>
I write a simple program to test benmark of infinispan but i got problem of lost data. I put many key-value but when i retrieve it return null.
Here is my program soucecode:
package vn.vccorp.benmark.infinispan;
import java.io.FileWriter;
import java.io.PrintWriter;
import java.net.URL;
import java.util.ArrayList;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;
import java.util.Map.Entry;
import java.util.Random;
import java.util.UUID;
import java.util.concurrent.Callable;
import java.util.concurrent.Executor;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
import org.infinispan.client.hotrod.RemoteCache;
import org.infinispan.client.hotrod.RemoteCacheManager;
public class Benmark implements Callable<Void> {
private static final int MAX_LENGHT = 20;
private static final int MIN_LENGHT = 8;
private Map<String, String> accs = new LinkedHashMap<String, String>();
private final Random random = new Random(System.currentTimeMillis());
private RemoteCache<String, String> rc;
private boolean getOperator = false;
public Benmark(RemoteCache<String, String> rc, int numAcc) {
generateRandomAccs(numAcc);
this.rc = rc;
}
/**
* @param args
* @throws InterruptedException
*/
public static void main(String[] args) throws InterruptedException {
URL resource = Thread.currentThread().getContextClassLoader()
.getResource("hotrod-client.properties");
RemoteCacheManager rcm = new RemoteCacheManager(resource, true);
RemoteCache<String, String> rc = rcm.getCache("evictionCache");
List<Benmark> bens = new ArrayList<Benmark>();
int numThreads = Runtime.getRuntime().availableProcessors() * 2;
int numAccsPerThread = 5000;
for (int i = 0; i < numThreads; ++i) {
bens.add(new Benmark(rc, numAccsPerThread));
}
long time = testOperator(bens);
System.out.println("finish test Put with "
+ (numThreads * numAccsPerThread) + " records in "
+ (time) + "ns");
for (Benmark benmark : bens) {
benmark.setGetOperator(true);
}
time = testOperator(bens);
System.out.println("finish test Get with "
+ (numThreads * numAccsPerThread) + " records in "
+ (time) + "ns");
rcm.stop();
saveDataTest(bens);
}
private static void saveDataTest(List<Benmark> bens) {
PrintWriter writer = null;
try {
writer = new PrintWriter(new FileWriter("data_test.txt"));
for (Benmark ben : bens) {
for (Entry<String, String> entry : ben.getAccs().entrySet()) {
writer.println(entry.getKey());
writer.println(entry.getValue());
}
}
} catch (Exception e) {
// TODO: handle exception
} finally {
if (writer != null) {
writer.close();
}
}
}
private static long testOperator(List<Benmark> bens) throws InterruptedException {
ExecutorService pool = Executors.newCachedThreadPool();
long time = System.nanoTime();
pool.invokeAll(bens);
pool.shutdown();
while (!pool.awaitTermination(1, TimeUnit.MINUTES)) {
}
long end = System.nanoTime();
return end - time;
}
private void generateRandomAccs(int numberAcc) {
String user = null;
String pass = null;
for (int i = 0; i < numberAcc;) {
user = randomString();
pass = randomString();
if (getAccs().put(user, pass) == null) {
++i;
}
}
}
private String randomString() {
// int len = MIN_LENGHT + random.nextInt(MAX_LENGHT - MIN_LENGHT);
// StringBuilder builder = new StringBuilder(len);
// for (int i = 0; i < len; ++i) {
// char c = (char) (32 + random.nextInt(126 - 32));
// builder.append(c);
// }
// return builder.toString();
return UUID.randomUUID().toString();
}
@Override
public Void call() {
if (!getOperator) {
System.out.println("Start test PUT");
long startPut = System.nanoTime();
for (Entry<String, String> acc : getAccs().entrySet()) {
rc.put(acc.getKey(), acc.getValue());
}
long endPut = System.nanoTime();
System.out
.println("Finish test PUT: " + (endPut - startPut) + "ns");
} else {
System.out.println("Start test GET");
long startGet = System.nanoTime();
for (Entry<String, String> acc : getAccs().entrySet()) {
if (rc.get(acc.getKey()) == null) {
System.err.println("Error get data");
break;
}
}
long endGet = System.nanoTime();
System.out
.println("Finish test GET: " + (endGet - startGet) + "ns");
}
return null;
}
public boolean isGetOperator() {
return getOperator;
}
public void setGetOperator(boolean getOperator) {
this.getOperator = getOperator;
}
public Map<String, String> getAccs() {
return accs;
}
public void setAccs(Map<String, String> accs) {
this.accs = accs;
}
}
> Lost data on remotecache get() after put()
> ------------------------------------------
>
> Key: ISPN-2779
> URL: https://issues.jboss.org/browse/ISPN-2779
> Project: Infinispan
> Issue Type: Bug
> Components: Distributed Cache, Eviction, Loaders and Stores, Server
> Affects Versions: 5.1.6.FINAL, 5.2.0.CR3
> Environment: Windows 7SP1 Pro
> JDK 7 or JRE6
> Reporter: ThienLong Hong
> Assignee: Tristan Tarrant
>
> I'm start server Infinispan on Ubuntu follow comand:
> {noformat}
> ./startServer.sh -r hotrod -c infinispan-distribution.xml -l 192.168.23.120 -Djgroups.bind_addr=192.168.23.120
> {noformat}
> Make sure we can open many file, /etc/security/limits.conf:
> * soft nofile 100002
> * hard nofile 100002
> Here is content of infinispan-distribution.xml:
> {noformat}
> <infinispan xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
> xsi:schemaLocation="urn:infinispan:config:5.1 http://www.infinispan.org/schemas/infinispan-config-5.1.xsd"
> xmlns="urn:infinispan:config:5.1">
> <global>
> <transport>
> <properties>
> <property name="configurationFile" value="jgroups-tcp.xml">
> </property></properties>
> </transport>
> </global>
> <default>
> <clustering mode="distribution">
> <sync />
> <hash numOwners="2" />
> </clustering>
> </default>
> <namedCache name="myCache">
> <clustering mode="distribution">
> <sync />
> <hash numOwners="2" />
> </clustering>
> </namedCache>
> <namedCache name="evictionCache">
> <clustering mode="distribution">
> <sync />
> <hash numOwners="2" rehashEnabled="true" rehashRpcTimeout="600000" numVirtualNodes="50"/>
> </clustering>
> <eviction
> maxEntries="10000"
> strategy="LRU"
> />
> <loaders passivation="true" preload="false">
> <loader class="org.infinispan.loaders.file.FileCacheStore" fetchPersistentState="true" purgeOnStartup="false">
> <properties>
> <property name="location" value="data"/>
> </properties>
> </loader>
> </loaders>
> </namedCache>
> </infinispan>
> {noformat}
> I write a simple program to test benmark of infinispan but i got problem of lost data. I put many key-value but when i retrieve it return null.
> Here is my program soucecode:
> {noformat}
> package vn.vccorp.benmark.infinispan;
> import java.io.FileWriter;
> import java.io.PrintWriter;
> import java.net.URL;
> import java.util.ArrayList;
> import java.util.LinkedHashMap;
> import java.util.List;
> import java.util.Map;
> import java.util.Map.Entry;
> import java.util.Random;
> import java.util.UUID;
> import java.util.concurrent.Callable;
> import java.util.concurrent.Executor;
> import java.util.concurrent.ExecutorService;
> import java.util.concurrent.Executors;
> import java.util.concurrent.TimeUnit;
> import org.infinispan.client.hotrod.RemoteCache;
> import org.infinispan.client.hotrod.RemoteCacheManager;
> public class Benmark implements Callable<Void> {
> private static final int MAX_LENGHT = 20;
> private static final int MIN_LENGHT = 8;
> private Map<String, String> accs = new LinkedHashMap<String, String>();
> private final Random random = new Random(System.currentTimeMillis());
> private RemoteCache<String, String> rc;
> private boolean getOperator = false;
> public Benmark(RemoteCache<String, String> rc, int numAcc) {
> generateRandomAccs(numAcc);
> this.rc = rc;
> }
> /**
> * @param args
> * @throws InterruptedException
> */
> public static void main(String[] args) throws InterruptedException {
> URL resource = Thread.currentThread().getContextClassLoader()
> .getResource("hotrod-client.properties");
> RemoteCacheManager rcm = new RemoteCacheManager(resource, true);
> RemoteCache<String, String> rc = rcm.getCache("evictionCache");
> List<Benmark> bens = new ArrayList<Benmark>();
> int numThreads = Runtime.getRuntime().availableProcessors() * 2;
> int numAccsPerThread = 5000;
> for (int i = 0; i < numThreads; ++i) {
> bens.add(new Benmark(rc, numAccsPerThread));
> }
> long time = testOperator(bens);
> System.out.println("finish test Put with "
> + (numThreads * numAccsPerThread) + " records in "
> + (time) + "ns");
> for (Benmark benmark : bens) {
> benmark.setGetOperator(true);
> }
> time = testOperator(bens);
> System.out.println("finish test Get with "
> + (numThreads * numAccsPerThread) + " records in "
> + (time) + "ns");
> rcm.stop();
> saveDataTest(bens);
> }
> private static void saveDataTest(List<Benmark> bens) {
> PrintWriter writer = null;
> try {
> writer = new PrintWriter(new FileWriter("data_test.txt"));
> for (Benmark ben : bens) {
> for (Entry<String, String> entry : ben.getAccs().entrySet()) {
> writer.println(entry.getKey());
> writer.println(entry.getValue());
> }
> }
> } catch (Exception e) {
> // TODO: handle exception
> } finally {
> if (writer != null) {
> writer.close();
> }
> }
> }
> private static long testOperator(List<Benmark> bens) throws InterruptedException {
> ExecutorService pool = Executors.newCachedThreadPool();
> long time = System.nanoTime();
> pool.invokeAll(bens);
> pool.shutdown();
> while (!pool.awaitTermination(1, TimeUnit.MINUTES)) {
> }
> long end = System.nanoTime();
> return end - time;
> }
> private void generateRandomAccs(int numberAcc) {
> String user = null;
> String pass = null;
> for (int i = 0; i < numberAcc;) {
> user = randomString();
> pass = randomString();
> if (getAccs().put(user, pass) == null) {
> ++i;
> }
> }
> }
> private String randomString() {
> // int len = MIN_LENGHT + random.nextInt(MAX_LENGHT - MIN_LENGHT);
> // StringBuilder builder = new StringBuilder(len);
> // for (int i = 0; i < len; ++i) {
> // char c = (char) (32 + random.nextInt(126 - 32));
> // builder.append(c);
> // }
> // return builder.toString();
> return UUID.randomUUID().toString();
> }
> @Override
> public Void call() {
> if (!getOperator) {
> System.out.println("Start test PUT");
> long startPut = System.nanoTime();
> for (Entry<String, String> acc : getAccs().entrySet()) {
> rc.put(acc.getKey(), acc.getValue());
> }
> long endPut = System.nanoTime();
> System.out
> .println("Finish test PUT: " + (endPut - startPut) + "ns");
> } else {
> System.out.println("Start test GET");
> long startGet = System.nanoTime();
> for (Entry<String, String> acc : getAccs().entrySet()) {
> if (rc.get(acc.getKey()) == null) {
> System.err.println("Error get data");
> break;
> }
> }
> long endGet = System.nanoTime();
> System.out
> .println("Finish test GET: " + (endGet - startGet) + "ns");
> }
> return null;
> }
> public boolean isGetOperator() {
> return getOperator;
> }
> public void setGetOperator(boolean getOperator) {
> this.getOperator = getOperator;
> }
> public Map<String, String> getAccs() {
> return accs;
> }
> public void setAccs(Map<String, String> accs) {
> this.accs = accs;
> }
> }
> {noformat}
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira
11 years, 2 months
[JBoss JIRA] (ISPN-2720) StateTransferPessimisticTest.testStateTransfer fails randomly
by Adrian Nistor (JIRA)
[ https://issues.jboss.org/browse/ISPN-2720?page=com.atlassian.jira.plugin.... ]
Adrian Nistor commented on ISPN-2720:
-------------------------------------
The test counts the owners of the key after state transfer by looking directly into the data container and finds too many because expiration was not taken into account.
> StateTransferPessimisticTest.testStateTransfer fails randomly
> -------------------------------------------------------------
>
> Key: ISPN-2720
> URL: https://issues.jboss.org/browse/ISPN-2720
> Project: Infinispan
> Issue Type: Bug
> Components: State transfer
> Affects Versions: 5.2.0.CR1
> Reporter: Galder Zamarreño
> Assignee: Adrian Nistor
> Labels: testsuite_stability
> Fix For: 5.2.1, 5.3.0.Alpha1
>
> Attachments: testStateTransfer-6.tgz
>
>
> {code}testStateTransfer(org.infinispan.statetransfer.StateTransferPessimisticTest) Time elapsed: 0.174 sec <<< FAILURE!
> java.lang.AssertionError: expected:<1> but was:<2>
> at org.junit.Assert.fail(Assert.java:93)
> at org.junit.Assert.failNotEquals(Assert.java:647)
> at org.junit.Assert.assertEquals(Assert.java:128)
> at org.junit.Assert.assertEquals(Assert.java:472)
> at org.junit.Assert.assertEquals(Assert.java:456)
> at org.infinispan.statetransfer.StateTransferPessimisticTest.testStateTransfer(StateTransferPessimisticTest.java:104)
> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
> at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
> at java.lang.reflect.Method.invoke(Method.java:597)
> at org.testng.internal.MethodInvocationHelper.invokeMethod(MethodInvocationHelper.java:80)
> at org.testng.internal.Invoker.invokeMethod(Invoker.java:715)
> at org.testng.internal.Invoker.invokeTestMethod(Invoker.java:907)
> at org.testng.internal.Invoker.invokeTestMethods(Invoker.java:1237)
> at org.testng.internal.TestMethodWorker.invokeTestMethods(TestMethodWorker.java:127)
> at org.testng.internal.TestMethodWorker.run(TestMethodWorker.java:111)
> at org.testng.TestRunner.privateRun(TestRunner.java:767)
> at org.testng.TestRunner.run(TestRunner.java:617)
> at org.testng.SuiteRunner.runTest(SuiteRunner.java:334)
> at org.testng.SuiteRunner.access$000(SuiteRunner.java:37)
> at org.testng.SuiteRunner$SuiteWorker.run(SuiteRunner.java:368)
> at org.testng.internal.thread.ThreadUtil$2.call(ThreadUtil.java:64)
> at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
> at java.util.concurrent.FutureTask.run(FutureTask.java:138)
> at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
> at java.lang.Thread.run(Thread.java:680){code}
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira
11 years, 2 months