Uploaded image for project: 'ActiveMQ'
  1. ActiveMQ
  2. AMQ-3325

PList temp store, chunk stream does not exist when broker under stress

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 5.5.0
    • Fix Version/s: 5.6.0
    • Component/s: Message Store
    • Environment:

      concurrency issue, multicore under load, sporadic occurrence, related to memory limits and dynamic destination creation/deletion

      Description

      apparent concurrency issue, multicore (8 cpu) under load, sporadic occurrence, related to memory limits and dynamic destination creation/deletion. Broker stack trace:

      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)

        Attachments

          Activity

            People

            • Assignee:
              gtully Gary Tully
              Reporter:
              gtully Gary Tully
            • Votes:
              0 Vote for this issue
              Watchers:
              0 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: