Uploaded image for project: 'AMQ Broker'
  1. AMQ Broker
  2. ENTMQBR-2100

AMQ 7.2.1: under heavy load: org.apache.activemq.artemis.core.paging.cursor.NonExistentPage: Invalid messageNumber passed

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Done
    • Icon: Major Major
    • AMQ 7.2.4.GA
    • AMQ 7.2.1.GA
    • None
    • None
    • Release Notes
    • +
    • Hide
      While a receiving transaction is committed to a paging operation, if the page is complete, a transaction operation deletes it. Previously, the transaction operation might delete the page before the receiving transaction could access it. This caused the receiving transaction to fail to find a message. In that case, you saw an exception. This issue is now resolved.
      Show
      While a receiving transaction is committed to a paging operation, if the page is complete, a transaction operation deletes it. Previously, the transaction operation might delete the page before the receiving transaction could access it. This caused the receiving transaction to fail to find a message. In that case, you saw an exception. This issue is now resolved.
    • Verified in a release
    • Hide

      1. Download and extract the attached broker.zip file. broker1 is the master and broker2 is the slave.
      2. Create the master/slave setup using attached broker files.
      3. Run master and slave broker.
      4. Run the attached test script (testScript.sh) which produces and consumes messages with high volume.
      5. After a few iterations the following logs appear when the consumer is running:

      [org.apache.activemq.artemis.utils.actors.OrderedExecutor] Invalid messageNumber passed = PagePositionImpl [pageNr=2, messageNr=11127, recordID=6573510] on null: org.apache.activemq.artemis.core.paging.cursor.NonExistentPage: Invalid messageNumber passed = PagePositionImpl [pageNr=2, messageNr=11127, recordID=6573510] on null

      6. Incorrect message count is displayed for this particular queue on hawtio console

      Expected
      1. This exception should not appear under high load
      2. Correct message count should be displayed on hawtio console.

      Show
      1. Download and extract the attached broker.zip file. broker1 is the master and broker2 is the slave. 2. Create the master/slave setup using attached broker files. 3. Run master and slave broker. 4. Run the attached test script (testScript.sh) which produces and consumes messages with high volume. 5. After a few iterations the following logs appear when the consumer is running: [org.apache.activemq.artemis.utils.actors.OrderedExecutor] Invalid messageNumber passed = PagePositionImpl [pageNr=2, messageNr=11127, recordID=6573510] on null : org.apache.activemq.artemis.core.paging.cursor.NonExistentPage: Invalid messageNumber passed = PagePositionImpl [pageNr=2, messageNr=11127, recordID=6573510] on null 6. Incorrect message count is displayed for this particular queue on hawtio console Expected 1. This exception should not appear under high load 2. Correct message count should be displayed on hawtio console.

      When AMQ broker is operated under heavy load. The following message is observed in artemis.log.

      [org.apache.activemq.artemis.utils.actors.OrderedExecutor] Invalid messageNumber passed = PagePositionImpl [pageNr=2, messageNr=11127, recordID=6573510] on null: org.apache.activemq.artemis.core.paging.cursor.NonExistentPage: Invalid messageNumber passed = PagePositionImpl [pageNr=2, messageNr=11127, recordID=6573510] on null
	at org.apache.activemq.artemis.core.paging.cursor.impl.PageCursorProviderImpl.getMessage(PageCursorProviderImpl.java:119) [artemis-server-2.6.3.redhat-00004.jar:2.6.3.redhat-00004]
	at org.apache.activemq.artemis.core.paging.cursor.impl.PageSubscriptionImpl.queryMessage(PageSubscriptionImpl.java:574) [artemis-server-2.6.3.redhat-00004.jar:2.6.3.redhat-00004]
	at org.apache.activemq.artemis.core.paging.cursor.PagedReferenceImpl.getPagedMessage(PagedReferenceImpl.java:101) [artemis-server-2.6.3.redhat-00004.jar:2.6.3.redhat-00004]
	at org.apache.activemq.artemis.core.paging.cursor.PagedReferenceImpl.getMessage(PagedReferenceImpl.java:88) [artemis-server-2.6.3.redhat-00004.jar:2.6.3.redhat-00004]
	at org.apache.activemq.artemis.core.server.impl.QueuePendingMessageMetrics.decrementMetrics(QueuePendingMessageMetrics.java:71) [artemis-server-2.6.3.redhat-00004.jar:2.6.3.redhat-00004]
	at org.apache.activemq.artemis.core.server.impl.QueueImpl.decDelivering(QueueImpl.java:3399) [artemis-server-2.6.3.redhat-00004.jar:2.6.3.redhat-00004]
	at org.apache.activemq.artemis.core.server.impl.QueueImpl.postAcknowledge(QueueImpl.java:3016) [artemis-server-2.6.3.redhat-00004.jar:2.6.3.redhat-00004]
	at org.apache.activemq.artemis.core.server.impl.RefsOperation.afterCommit(RefsOperation.java:157) [artemis-server-2.6.3.redhat-00004.jar:2.6.3.redhat-00004]
	at org.apache.activemq.artemis.core.transaction.impl.TransactionImpl.afterCommit(TransactionImpl.java:546) [artemis-server-2.6.3.redhat-00004.jar:2.6.3.redhat-00004]
	at org.apache.activemq.artemis.core.transaction.impl.TransactionImpl.access$100(TransactionImpl.java:38) [artemis-server-2.6.3.redhat-00004.jar:2.6.3.redhat-00004]
	at org.apache.activemq.artemis.core.transaction.impl.TransactionImpl$2.done(TransactionImpl.java:304) [artemis-server-2.6.3.redhat-00004.jar:2.6.3.redhat-00004]
	at org.apache.activemq.artemis.core.persistence.impl.journal.OperationContextImpl$1.run(OperationContextImpl.java:236) [artemis-server-2.6.3.redhat-00004.jar:2.6.3.redhat-00004]
	at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:42) [artemis-commons-2.6.3.redhat-00004.jar:2.6.3.redhat-00004]
	at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:31) [artemis-commons-2.6.3.redhat-00004.jar:2.6.3.redhat-00004]
	at org.apache.activemq.artemis.utils.actors.ProcessorBase.executePendingTasks(ProcessorBase.java:66) [artemis-commons-2.6.3.redhat-00004.jar:2.6.3.redhat-00004]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [rt.jar:1.8.0_181]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [rt.jar:1.8.0_181]
	at org.apache.activemq.artemis.utils.ActiveMQThreadFactory$1.run(ActiveMQThreadFactory.java:118) [artemis-commons-2.6.3.redhat-00004.jar:2.6.3.redhat-00004]

      As a result of this, incorrect message count is displayed on the hawtio console for this queue. See attachments.

        2. Incorrect message count.png
          153 kB
          Avinash Dongre
        3. No messages.png
          100 kB
          Avinash Dongre
        4. testScript.sh
          0.7 kB
          Avinash Dongre

              gaohoward Howard Gao
              rhn-support-adongre Avinash Dongre
              Michal Toth Michal Toth
              Votes:
              2 Vote for this issue
              Watchers:
              13 Start watching this issue

                Created:
                Updated:
                Resolved:

                  Estimated:
                  Original Estimate - 0 minutes
                  0m
                  Remaining:
                  Remaining Estimate - 0 minutes
                  0m
                  Logged:
                  Time Spent - 1 day, 5 hours
                  1d 5h