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

Failed to fill batch | org.apache.activemq.broker.region.cursors.AbstractStoreCursor | Scheduler java.io.EOFException: Chunk stream does not exist, page: 1723 is marked free

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Open
    • Priority: Major
    • Resolution: Unresolved
    • Affects Version/s: 5.14.5
    • Fix Version/s: None
    • Component/s: KahaDB, Message Store
    • Labels:
      None
    • Environment:

      Description

      2018-05-09 03:08:24,002 | ERROR | org.apache.activemq.broker.region.cursors.QueueStorePrefetch@b23483a:CMP_ExternalEventQueue,batchResetNeeded=false,size=916,cacheEnabled=false,maxBatchSize:400,hasSpace:true,pendingCachedIds.size:0,lastSyncCachedId:null,lastSyncCachedId-seq:null,lastAsyncCachedId:null,lastAsyncCachedId-seq:null,store=permits:10000,sd=nextSeq:8594,lastRet:MessageOrderCursor:[def:7667, low:0, high:0],pending:0 - Failed to fill batch | org.apache.activemq.broker.region.cursors.AbstractStoreCursor | ActiveMQ Broker[CMDBROKER-10.203.14.145] Scheduler
      java.io.EOFException: Chunk stream does not exist, page: 1723 is marked free
      at org.apache.activemq.store.kahadb.disk.page.Transaction$2.readPage(Transaction.java:470)[activemq-kahadb-store-5.14.5.jar:5.14.5]
      at org.apache.activemq.store.kahadb.disk.page.Transaction$2.<init>(Transaction.java:447)[activemq-kahadb-store-5.14.5.jar:5.14.5]
      at org.apache.activemq.store.kahadb.disk.page.Transaction.openInputStream(Transaction.java:444)[activemq-kahadb-store-5.14.5.jar:5.14.5]
      at org.apache.activemq.store.kahadb.disk.page.Transaction.load(Transaction.java:420)[activemq-kahadb-store-5.14.5.jar:5.14.5]
      at org.apache.activemq.store.kahadb.disk.page.Transaction.load(Transaction.java:377)[activemq-kahadb-store-5.14.5.jar:5.14.5]
      at org.apache.activemq.store.kahadb.disk.index.BTreeIndex.loadNode(BTreeIndex.java:266)[activemq-kahadb-store-5.14.5.jar:5.14.5]
      at org.apache.activemq.store.kahadb.disk.index.BTreeNode.getChild(BTreeNode.java:233)[activemq-kahadb-store-5.14.5.jar:5.14.5]
      at org.apache.activemq.store.kahadb.disk.index.BTreeNode.getLeafNode(BTreeNode.java:684)[activemq-kahadb-store-5.14.5.jar:5.14.5]
      at org.apache.activemq.store.kahadb.disk.index.BTreeNode.iterator(BTreeNode.java:647)[activemq-kahadb-store-5.14.5.jar:5.14.5]
      at org.apache.activemq.store.kahadb.disk.index.BTreeIndex.iterator(BTreeIndex.java:236)[activemq-kahadb-store-5.14.5.jar:5.14.5]
      at org.apache.activemq.store.kahadb.MessageDatabase$MessageOrderIndex$MessageOrderIterator.<init>(MessageDatabase.java:3739)[activemq-kahadb-store-5.14.5.jar:5.14.5]
      at org.apache.activemq.store.kahadb.MessageDatabase$MessageOrderIndex.iterator(MessageDatabase.java:3692)[activemq-kahadb-store-5.14.5.jar:5.14.5]
      at org.apache.activemq.store.kahadb.KahaDBStore$KahaDBMessageStore$4.execute(KahaDBStore.java:588)[activemq-kahadb-store-5.14.5.jar:5.14.5]
      at org.apache.activemq.store.kahadb.disk.page.Transaction.execute(Transaction.java:779)[activemq-kahadb-store-5.14.5.jar:5.14.5]
      at org.apache.activemq.store.kahadb.KahaDBStore$KahaDBMessageStore.recoverNextMessages(KahaDBStore.java:582)[activemq-kahadb-store-5.14.5.jar:5.14.5]
      at org.apache.activemq.store.ProxyMessageStore.recoverNextMessages(ProxyMessageStore.java:110)[activemq-broker-5.14.5.jar:5.14.5]
      at org.apache.activemq.broker.region.cursors.QueueStorePrefetch.doFillBatch(QueueStorePrefetch.java:120)[activemq-broker-5.14.5.jar:5.14.5]
      at org.apache.activemq.broker.region.cursors.AbstractStoreCursor.fillBatch(AbstractStoreCursor.java:420)[activemq-broker-5.14.5.jar:5.14.5]
      at org.apache.activemq.broker.region.cursors.AbstractStoreCursor.hasNext(AbstractStoreCursor.java:202)[activemq-broker-5.14.5.jar:5.14.5]
      at org.apache.activemq.broker.region.cursors.StoreQueueCursor.hasNext(StoreQueueCursor.java:139)[activemq-broker-5.14.5.jar:5.14.5]
      at org.apache.activemq.broker.region.Queue.doPageInForDispatch(Queue.java:1942)[activemq-broker-5.14.5.jar:5.14.5]
      at org.apache.activemq.broker.region.Queue.pageInMessages(Queue.java:2170)[activemq-broker-5.14.5.jar:5.14.5]
      at org.apache.activemq.broker.region.Queue.doBrowse(Queue.java:1132)[activemq-broker-5.14.5.jar:5.14.5]
      at org.apache.activemq.broker.region.Queue.expireMessages(Queue.java:912)[activemq-broker-5.14.5.jar:5.14.5]
      at org.apache.activemq.broker.region.Queue.access$100(Queue.java:104)[activemq-broker-5.14.5.jar:5.14.5]
      at org.apache.activemq.broker.region.Queue$2.run(Queue.java:146)[activemq-broker-5.14.5.jar:5.14.5]
      at org.apache.activemq.thread.SchedulerTimerTask.run(SchedulerTimerTask.java:33)[activemq-client-5.14.5.jar:5.14.5]
      at java.util.TimerThread.mainLoop(Timer.java:566)[:1.8.0]
      at java.util.TimerThread.run(Timer.java:516)[:1.8.0]

        Attachments

        1. activemq.log
          877 kB
          Alessandro Capomassi
        2. activemq.xml
          6 kB
          Alessandro Capomassi

          Activity

            People

            • Assignee:
              jbonofre Jean-Baptiste Onofré
              Reporter:
              acapom Alessandro Capomassi
            • Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

              • Created:
                Updated: