Hi Eric, I ended up updating the ActiveMQ libraries to the latest ones, 5.6.0, and changing the broker to use the KahaDB persistence engine instead of the AMQ one. It has worked fine so far, it did not crash during the load test.
-Valentin On Tue, Sep 18, 2012 at 1:22 AM, Eric Charles <[email protected]> wrote: > Hi, > > Thx for stressing James :) > > This is an issue related to ActiveMQ queues. Can be its configuration, or > the way we use it... > > I had a quick look, but didn't find anything relevant for now. Could you > please open a JIRA for this. > > Alternatively, would you be interested in testing with a file based queuing > system which should better perform. > > Thx, Eric > > > > On 17/09/2012 02:29, Valentin Munteanu wrote: >> >> Hi, >> >> I ran a load testing on a james-3.0-beta3 and at some point I started >> seeing a lot of "Page Size overflow: pageSize is 1024 trying to write >> 1031" warnings in the logs. Full stack trace bellow. As far as I can >> tell it still accepts messages but nothing is delivered. Do you guys >> have any hints on how I troubleshoot this? >> >> Thanks. >> >> >> >> --------------------------------------------- >> >> Thu Sep 06 23:00:00 2012 UTC <HOST_NAME> [WARN] (AMQPersistenceAdaptor >> Task) org.apache.activemq.store.amq.AMQMessageStore: Message could not >> be added to long term store: java.io.IOException: Page Size overflow: >> pageSize is 1024 trying to write 1031 >> java.lang.RuntimeException: java.io.IOException: Page Size overflow: >> pageSize is 1024 trying to write 1031 >> at >> org.apache.activemq.kaha.impl.container.MapContainerImpl.containsKey(MapContainerImpl.java:198) >> at >> org.apache.activemq.store.kahadaptor.KahaReferenceStore.isDuplicate(KahaReferenceStore.java:176) >> at >> org.apache.activemq.store.kahadaptor.KahaReferenceStore.addMessageReference(KahaReferenceStore.java:160) >> at >> org.apache.activemq.store.amq.AMQMessageStore$4.execute(AMQMessageStore.java:387) >> at >> org.apache.activemq.util.TransactionTemplate.run(TransactionTemplate.java:44) >> at >> org.apache.activemq.store.amq.AMQMessageStore.doAsyncWrite(AMQMessageStore.java:377) >> at >> org.apache.activemq.store.amq.AMQMessageStore.asyncWrite(AMQMessageStore.java:343) >> at >> org.apache.activemq.store.amq.AMQMessageStore$1.iterate(AMQMessageStore.java:91) >> at >> org.apache.activemq.thread.PooledTaskRunner.runTask(PooledTaskRunner.java:122) >> at >> org.apache.activemq.thread.PooledTaskRunner$1.run(PooledTaskRunner.java:43) >> 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: java.io.IOException: Page Size overflow: pageSize is 1024 >> trying to write 1031 >> at >> org.apache.activemq.kaha.impl.index.hash.HashIndex.writeFullPage(HashIndex.java:394) >> at >> org.apache.activemq.kaha.impl.index.hash.HashPageInfo.end(HashPageInfo.java:103) >> at >> org.apache.activemq.kaha.impl.index.hash.HashBin.end(HashBin.java:337) >> at >> org.apache.activemq.kaha.impl.index.hash.HashBin.find(HashBin.java:123) >> at >> org.apache.activemq.kaha.impl.index.hash.HashIndex.get(HashIndex.java:294) >> at >> org.apache.activemq.kaha.impl.index.hash.HashIndex.containsKey(HashIndex.java:319) >> at >> org.apache.activemq.kaha.impl.container.MapContainerImpl.containsKey(MapContainerImpl.java:195) >> ... 12 more >> Thu Sep 06 23:00:00 2012 UTC <HOST_NAME> [ERROR] >> (AMQPersistenceAdaptor Task) >> org.apache.activemq.kaha.impl.container.MapContainerImpl: Failed >> trying to find key: ID:<HOST_NAME>-40879-1346962262285-3:1:2773:1:2 >> java.io.IOException: Page Size overflow: pageSize is 1024 trying to write >> 1031 >> at >> org.apache.activemq.kaha.impl.index.hash.HashIndex.writeFullPage(HashIndex.java:394) >> at >> org.apache.activemq.kaha.impl.index.hash.HashPageInfo.end(HashPageInfo.java:103) >> at >> org.apache.activemq.kaha.impl.index.hash.HashBin.end(HashBin.java:337) >> at >> org.apache.activemq.kaha.impl.index.hash.HashBin.find(HashBin.java:123) >> at >> org.apache.activemq.kaha.impl.index.hash.HashIndex.get(HashIndex.java:294) >> at >> org.apache.activemq.kaha.impl.index.hash.HashIndex.containsKey(HashIndex.java:319) >> at >> org.apache.activemq.kaha.impl.container.MapContainerImpl.containsKey(MapContainerImpl.java:195) >> at >> org.apache.activemq.store.kahadaptor.KahaReferenceStore.isDuplicate(KahaReferenceStore.java:176) >> at >> org.apache.activemq.store.kahadaptor.KahaReferenceStore.addMessageReference(KahaReferenceStore.java:160) >> at >> org.apache.activemq.store.amq.AMQMessageStore$4.execute(AMQMessageStore.java:387) >> at >> org.apache.activemq.util.TransactionTemplate.run(TransactionTemplate.java:44) >> at >> org.apache.activemq.store.amq.AMQMessageStore.doAsyncWrite(AMQMessageStore.java:377) >> at >> org.apache.activemq.store.amq.AMQMessageStore.asyncWrite(AMQMessageStore.java:343) >> at >> org.apache.activemq.store.amq.AMQMessageStore$1.iterate(AMQMessageStore.java:91) >> at >> org.apache.activemq.thread.PooledTaskRunner.runTask(PooledTaskRunner.java:122) >> at >> org.apache.activemq.thread.PooledTaskRunner$1.run(PooledTaskRunner.java:43) >> 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) >> >> --------------------------------------------------------------------- >> To unsubscribe, e-mail: [email protected] >> For additional commands, e-mail: [email protected] >> > > --------------------------------------------------------------------- > To unsubscribe, e-mail: [email protected] > For additional commands, e-mail: [email protected] > --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
