Uploaded image for project: 'Qpid'
  1. Qpid
  2. QPID-4319

Perf test VaryingNumberOfParticipants produced broker exception Metadata not found for message with id nnnnn [error code 541: internal error]

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Closed
    • Major
    • Resolution: Fixed
    • 0.18
    • 0.30
    • Broker-J
    • None

    Description

      Running the complete perf testsuite (perftest/etc/testdef), I ran into the following failure. The test had reached VaryingNumberOfParticipants - 1 consumer - 10 producers - PERSISTENT and the Broker was struggling for memory (1gb heap).

      The client stack was:

      2012-09-18 14:57:56,197 ERROR [IoSender - localhost/127.0.0.1:5672] [IoSender] error in write thread
      java.net.SocketException: Broken pipe
              at java.net.SocketOutputStream.socketWrite0(Native Method)
              at java.net.SocketOutputStream.socketWrite(SocketOutputStream.java:92)
              at java.net.SocketOutputStream.write(SocketOutputStream.java:136)
              at org.apache.qpid.transport.network.io.IoSender.run(IoSender.java:313)
              at java.lang.Thread.run(Thread.java:662)
      
      

      whilst the Broker stack was:

      2012-09-18 14:57:56,094 ERROR [IoReceiver - /127.0.0.1:49348] (AMQProtocolEngine.java:258) - Unexpected exception when processing datablock
      java.lang.RuntimeException: org.apache.qpid.AMQStoreException: Metadata not found for message with id 22902968 [error code 541: internal error]
              at org.apache.qpid.server.store.berkeleydb.AbstractBDBMessageStore$StoredBDBMessage.getMetaData(AbstractBDBMessageStore.java:1615)
              at org.apache.qpid.server.message.AMQMessage.getMessageMetaData(AMQMessage.java:93)
              at org.apache.qpid.server.message.AMQMessage.getArrivalTime(AMQMessage.java:160)
              at org.apache.qpid.server.queue.SimpleAMQQueue.getOldestMessageArrivalTime(SimpleAMQQueue.java:1057)
              at org.apache.qpid.server.queue.NotificationCheck$4.notifyIfNecessary(NotificationCheck.java:104)
              at org.apache.qpid.server.queue.SimpleAMQQueue.checkForNotification(SimpleAMQQueue.java:2327)
              at org.apache.qpid.server.queue.SimpleAMQQueue.enqueue(SimpleAMQQueue.java:766)
              at org.apache.qpid.server.AMQChannel$MessageDeliveryAction.postCommit(AMQChannel.java:1207)
              at org.apache.qpid.server.AMQChannel$AsyncCommand.complete(AMQChannel.java:1674)
              at org.apache.qpid.server.AMQChannel.sync(AMQChannel.java:1644)
              at org.apache.qpid.server.AMQChannel.receivedComplete(AMQChannel.java:221)
              at org.apache.qpid.server.protocol.AMQProtocolEngine.receiveComplete(AMQProtocolEngine.java:271)
              at org.apache.qpid.server.protocol.AMQProtocolEngine.received(AMQProtocolEngine.java:254)
              at org.apache.qpid.server.protocol.AMQProtocolEngine.received(AMQProtocolEngine.java:85)
              at org.apache.qpid.server.protocol.MultiVersionProtocolEngine.received(MultiVersionProtocolEngine.java:118)
              at org.apache.qpid.server.protocol.MultiVersionProtocolEngine.received(MultiVersionProtocolEngine.java:37)
              at org.apache.qpid.transport.network.io.IoReceiver.run(IoReceiver.java:152)
              at java.lang.Thread.run(Thread.java:662)
      Caused by: org.apache.qpid.AMQStoreException: Metadata not found for message with id 22902968 [error code 541: internal error]
              at org.apache.qpid.server.store.berkeleydb.AbstractBDBMessageStore.getMessageMetaData(AbstractBDBMessageStore.java:1417)
              at org.apache.qpid.server.store.berkeleydb.AbstractBDBMessageStore$StoredBDBMessage.getMetaData(AbstractBDBMessageStore.java:1611)
      

      Attachments

        Issue Links

          Activity

            People

              kwall Keith Wall
              kwall Keith Wall
              Votes:
              2 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: