Return-Path: X-Original-To: apmail-activemq-dev-archive@www.apache.org Delivered-To: apmail-activemq-dev-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 220869076 for ; Fri, 13 Jan 2012 14:13:05 +0000 (UTC) Received: (qmail 35187 invoked by uid 500); 13 Jan 2012 14:13:04 -0000 Delivered-To: apmail-activemq-dev-archive@activemq.apache.org Received: (qmail 35110 invoked by uid 500); 13 Jan 2012 14:13:04 -0000 Mailing-List: contact dev-help@activemq.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@activemq.apache.org Delivered-To: mailing list dev@activemq.apache.org Received: (qmail 35096 invoked by uid 99); 13 Jan 2012 14:13:03 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 13 Jan 2012 14:13:03 +0000 X-ASF-Spam-Status: No, hits=-2000.0 required=5.0 tests=ALL_TRUSTED,T_RP_MATCHES_RCVD X-Spam-Check-By: apache.org Received: from [140.211.11.116] (HELO hel.zones.apache.org) (140.211.11.116) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 13 Jan 2012 14:13:01 +0000 Received: from hel.zones.apache.org (hel.zones.apache.org [140.211.11.116]) by hel.zones.apache.org (Postfix) with ESMTP id 7C6761491C2 for ; Fri, 13 Jan 2012 14:12:41 +0000 (UTC) Date: Fri, 13 Jan 2012 14:12:41 +0000 (UTC) From: "Timothy Bish (Resolved) (JIRA)" To: dev@activemq.apache.org Message-ID: <142029001.37832.1326463961528.JavaMail.tomcat@hel.zones.apache.org> In-Reply-To: <899819773.4026.1325670458974.JavaMail.tomcat@hel.zones.apache.org> Subject: [jira] [Resolved] (AMQ-3649) NPE when KahaDB fails to store to Journal with EOFException MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 [ https://issues.apache.org/jira/browse/AMQ-3649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timothy Bish resolved AMQ-3649. ------------------------------- Resolution: Fixed Fix Version/s: 5.6.0 fix applied. Thanks. > 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 > Fix For: 5.6.0 > > 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.(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