activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Stevo Slavic (Updated) (JIRA)" <j...@apache.org>
Subject [jira] [Updated] (AMQ-3649) NPE when KahaDB fails to store to Journal with EOFException
Date Wed, 04 Jan 2012 09:49:38 GMT

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

Stevo Slavic updated AMQ-3649:
------------------------------

    Attachment: DefaultIOExceptionHandler.java.patch

Attaching patch [^DefaultIOExceptionHandler.java.patch]
                
> NPE when KahaDB fails to store to Journal with EOFException
> -----------------------------------------------------------
>
>                 Key: AMQ-3649
>                 URL: https://issues.apache.org/jira/browse/AMQ-3649
>             Project: ActiveMQ
>          Issue Type: Bug
>          Components: Message Store
>    Affects Versions: 5.5.0
>            Reporter: Stevo Slavic
>            Priority: Trivial
>         Attachments: DefaultIOExceptionHandler.java.patch
>
>
> {noformat}
> 2012-01-03 19:17:50,646 | DEBUG | commit: TX:ID:foo-7365-1325617993757-0:1:1 syncCount:
2 | org.apache.activemq.transaction.LocalTransaction | ActiveMQ Transport: tcp:///bar:13219
> 2012-01-03 19:17:50,650 | ERROR | KahaDB failed to store to Journal | org.apache.activemq.store.kahadb.MessageDatabase
| ActiveMQ Transport: tcp:///bar:13219
> java.io.EOFException
> 	at java.io.RandomAccessFile.readFully(RandomAccessFile.java:383)
> 	at java.io.RandomAccessFile.readFully(RandomAccessFile.java:361)
> 	at org.apache.kahadb.page.PageFile.readPage(PageFile.java:779)
> 	at org.apache.kahadb.page.Transaction$2.readPage(Transaction.java:440)
> 	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.kahadb.index.BTreeIndex.loadNode(BTreeIndex.java:262)
> 	at org.apache.kahadb.index.BTreeIndex.getRoot(BTreeIndex.java:174)
> 	at org.apache.kahadb.index.BTreeIndex.put(BTreeIndex.java:189)
> 	at org.apache.activemq.store.kahadb.MessageDatabase.upadateIndex(MessageDatabase.java:1026)
> 	at org.apache.activemq.store.kahadb.MessageDatabase$AddOpperation.execute(MessageDatabase.java:1777)
> 	at org.apache.activemq.store.kahadb.MessageDatabase$18.execute(MessageDatabase.java:976)
> 	at org.apache.kahadb.page.Transaction.execute(Transaction.java:728)
> 	at org.apache.activemq.store.kahadb.MessageDatabase.process(MessageDatabase.java:973)
> 	at org.apache.activemq.store.kahadb.MessageDatabase$13.visit(MessageDatabase.java:874)
> 	at org.apache.activemq.store.kahadb.data.KahaCommitCommand.visit(KahaCommitCommand.java:130)
> 	at org.apache.activemq.store.kahadb.MessageDatabase.process(MessageDatabase.java:856)
> 	at org.apache.activemq.store.kahadb.MessageDatabase.store(MessageDatabase.java:783)
> 	at org.apache.activemq.store.kahadb.KahaDBTransactionStore.commit(KahaDBTransactionStore.java:270)
> 	at org.apache.activemq.transaction.LocalTransaction.commit(LocalTransaction.java:72)
> 	at org.apache.activemq.broker.TransactionBroker.commitTransaction(TransactionBroker.java:173)
> 	at org.apache.activemq.broker.MutableBrokerFilter.commitTransaction(MutableBrokerFilter.java:103)
> 	at org.apache.activemq.broker.TransportConnection.processCommitTransactionOnePhase(TransportConnection.java:420)
> 	at org.apache.activemq.command.TransactionInfo.visit(TransactionInfo.java:100)
> 	at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:306)
> 	at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:179)
> 	at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:69)
> 	at org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:113)
> 	at org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:227)
> 	at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83)
> 	at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:220)
> 	at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:202)
> 	at java.lang.Thread.run(Thread.java:619)
> 2012-01-03 19:17:50,650 | WARN  | Store COMMIT FAILED:  | org.apache.activemq.transaction.LocalTransaction
| ActiveMQ Transport: tcp:///bar:13219
> java.lang.NullPointerException
> 	at org.apache.activemq.util.DefaultIOExceptionHandler.handle(DefaultIOExceptionHandler.java:54)
> 	at org.apache.activemq.broker.BrokerService.handleIOException(BrokerService.java:2193)
> 	at org.apache.activemq.store.kahadb.MessageDatabase.store(MessageDatabase.java:804)
> 	at org.apache.activemq.store.kahadb.KahaDBTransactionStore.commit(KahaDBTransactionStore.java:270)
> 	at org.apache.activemq.transaction.LocalTransaction.commit(LocalTransaction.java:72)
> 	at org.apache.activemq.broker.TransactionBroker.commitTransaction(TransactionBroker.java:173)
> 	at org.apache.activemq.broker.MutableBrokerFilter.commitTransaction(MutableBrokerFilter.java:103)
> 	at org.apache.activemq.broker.TransportConnection.processCommitTransactionOnePhase(TransportConnection.java:420)
> 	at org.apache.activemq.command.TransactionInfo.visit(TransactionInfo.java:100)
> 	at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:306)
> 	at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:179)
> 	at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:69)
> 	at org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:113)
> 	at org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:227)
> 	at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83)
> 	at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:220)
> 	at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:202)
> 	at java.lang.Thread.run(Thread.java:619)
> 2012-01-03 19:17:50,651 | DEBUG | rollback: TX:ID:foo-7365-1325617993757-0:1:1 syncCount:
2 | org.apache.activemq.transaction.LocalTransaction | ActiveMQ Transport: tcp:///bar:13219
> 2012-01-03 19:17:50,651 | DEBUG | Error occured while processing sync command: TransactionInfo
{commandId = 229, responseRequired = true, type = 2, connectionId = ID:foo-7365-1325617993757-0:1,
transactionId = TX:ID:foo-7365-1325617993757-0:1:1}, exception: javax.transaction.xa.XAException:
STORE COMMIT FAILED: Transaction rolled back. | org.apache.activemq.broker.TransportConnection.Service
| ActiveMQ Transport: tcp:///bar:13219
> javax.transaction.xa.XAException: STORE COMMIT FAILED: Transaction rolled back.
> 	at org.apache.activemq.transaction.LocalTransaction.commit(LocalTransaction.java:77)
> 	at org.apache.activemq.broker.TransactionBroker.commitTransaction(TransactionBroker.java:173)
> 	at org.apache.activemq.broker.MutableBrokerFilter.commitTransaction(MutableBrokerFilter.java:103)
> 	at org.apache.activemq.broker.TransportConnection.processCommitTransactionOnePhase(TransportConnection.java:420)
> 	at org.apache.activemq.command.TransactionInfo.visit(TransactionInfo.java:100)
> 	at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:306)
> 	at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:179)
> 	at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:69)
> 	at org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:113)
> 	at org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:227)
> 	at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83)
> 	at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:220)
> 	at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:202)
> 	at java.lang.Thread.run(Thread.java:619)
> Caused by: java.lang.NullPointerException
> 	at org.apache.activemq.util.DefaultIOExceptionHandler.handle(DefaultIOExceptionHandler.java:54)
> 	at org.apache.activemq.broker.BrokerService.handleIOException(BrokerService.java:2193)
> 	at org.apache.activemq.store.kahadb.MessageDatabase.store(MessageDatabase.java:804)
> 	at org.apache.activemq.store.kahadb.KahaDBTransactionStore.commit(KahaDBTransactionStore.java:270)
> 	at org.apache.activemq.transaction.LocalTransaction.commit(LocalTransaction.java:72)
> 	... 13 more
> {noformat}

--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira

        

Mime
View raw message