activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Gary Tully (JIRA)" <j...@apache.org>
Subject [jira] [Resolved] (AMQ-3325) PList temp store, chunk stream does not exist when broker under stress
Date Tue, 17 May 2011 09:22:47 GMT

     [ https://issues.apache.org/jira/browse/AMQ-3325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

Gary Tully resolved AMQ-3325.
-----------------------------

    Resolution: Fixed

add/remove of a plist needs to be synced with additions to the store as they share pages.

http://svn.apache.org/viewvc?rev=1104075&view=rev

> PList temp store,  chunk stream does not exist when broker under stress
> -----------------------------------------------------------------------
>
>                 Key: AMQ-3325
>                 URL: https://issues.apache.org/jira/browse/AMQ-3325
>             Project: ActiveMQ
>          Issue Type: Bug
>          Components: Message Store
>    Affects Versions: 5.5.0
>         Environment: concurrency issue, multicore under load, sporadic occurrence, related
to memory limits and dynamic destination creation/deletion
>            Reporter: Gary Tully
>            Assignee: Gary Tully
>              Labels: FilePendingMessageCursor, Temp
>             Fix For: 5.6.0
>
>
> apparent concurrency issue, multicore (8 cpu) under load, sporadic occurrence, related
to memory limits and dynamic destination creation/deletion. Broker stack trace:
> {code}2011-04-07 08:04:07,295 [Queue:loadq-4  ] ERROR FilePendingMessageCursor      
- I/O error
> java.io.EOFException: Chunk stream does not exist at page: 198
> 	at org.apache.kahadb.page.Transaction$2.readPage(Transaction.java:454)
> 	at org.apache.kahadb.page.Transaction$2.<init>(Transaction.java:431)
> 	at org.apache.kahadb.page.Transaction.openInputStream(Transaction.java:428)
> 	at org.apache.kahadb.page.Transaction.load(Transaction.java:404)
> 	at org.apache.kahadb.page.Transaction.load(Transaction.java:361)
> 	at org.apache.activemq.store.kahadb.plist.PList.loadEntry(PList.java:468)
> 	at org.apache.activemq.store.kahadb.plist.PList.getNext(PList.java:483)
> 	at org.apache.activemq.store.kahadb.plist.PList$10.execute(PList.java:312)
> 	at org.apache.kahadb.page.Transaction.execute(Transaction.java:728)
> 	at org.apache.activemq.store.kahadb.plist.PList.getNext(PList.java:310)
> 	at org.apache.activemq.broker.region.cursors.FilePendingMessageCursor$DiskIterator.next(FilePendingMessageCursor.java:500)
> 	at org.apache.activemq.broker.region.cursors.FilePendingMessageCursor$DiskIterator.next(FilePendingMessageCursor.java:473)
> 	at org.apache.activemq.broker.region.cursors.FilePendingMessageCursor.next(FilePendingMessageCursor.java:293)
> 	at org.apache.activemq.broker.region.Queue.doPageInForDispatch(Queue.java:1714)
> 	at org.apache.activemq.broker.region.Queue.pageInMessages(Queue.java:1932)
> 	at org.apache.activemq.broker.region.Queue.iterate(Queue.java:1440)
> 	at org.apache.activemq.thread.DedicatedTaskRunner.runTask(DedicatedTaskRunner.java:104)
> 	at org.apache.activemq.thread.DedicatedTaskRunner$1.run(DedicatedTaskRunner.java:42){code}

--
This message is automatically generated by JIRA.
For more information on JIRA, see: http://www.atlassian.com/software/jira

Mime
View raw message