activemq-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Timothy Bish (JIRA)" <j...@apache.org>
Subject [jira] [Closed] (AMQ-5026) Replicated LevelDB Store getting EOF exception
Date Wed, 01 Feb 2017 21:17:51 GMT

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

Timothy Bish closed AMQ-5026.
-----------------------------
    Resolution: Won't Fix

LevelDB has been deprecated and is no longer being maintained.  

> Replicated LevelDB Store getting EOF exception
> ----------------------------------------------
>
>                 Key: AMQ-5026
>                 URL: https://issues.apache.org/jira/browse/AMQ-5026
>             Project: ActiveMQ
>          Issue Type: Bug
>          Components: activemq-leveldb-store
>    Affects Versions: 5.10.0
>            Reporter: kal patel
>
> 3 brokers setup for ReplicatedLevelDB master/slave conf. 
> running producer and slow consumer and doing failover by stopping master broker. 
> After few failovers, the leveldb throws EOF exception while reading record from the store.
 
> using the latest source code from activemq 5.10 branch. 
> The file that has the issue: 
> [root@vmx0568 data]# ls -l /solidstate/ldbkp/000000001f4022e4.log 
> -rw-r--r--. 1 root root 91500224 Jan 17 14:44 /solidstate/ldbkp/000000001f4022e4.log

> [root@vmx0568 data]# 
> Client | main 
> 2014-01-17 14:44:19,118 | INFO  | locator read: DataLocator(24b41aac, 2283) | org.apache.activemq.leveldb.LevelDBClient
| main 
> 2014-01-17 14:44:19,118 | INFO  | Seq read: 260217 | org.apache.activemq.leveldb.LevelDBClient
| main 
> 2014-01-17 14:44:19,118 | INFO  | locator read: DataLocator(24b423ee, 2283) | org.apache.activemq.leveldb.LevelDBClient
| main 
> 2014-01-17 14:44:19,118 | INFO  | Seq read: 260218 | org.apache.activemq.leveldb.LevelDBClient
| main 
> 2014-01-17 14:44:19,118 | INFO  | locator read: DataLocator(24b42d02, 2283) | org.apache.activemq.leveldb.LevelDBClient
| main 
> 2014-01-17 14:44:19,118 | INFO  | Seq read: 260219 | org.apache.activemq.leveldb.LevelDBClient
| main 
> 2014-01-17 14:44:19,118 | INFO  | locator read: DataLocator(24b43628, 2283) | org.apache.activemq.leveldb.LevelDBClient
| main 
> 2014-01-17 14:44:19,118 | INFO  | Seq read: 260220 | org.apache.activemq.leveldb.LevelDBClient
| main 
> 2014-01-17 14:44:19,118 | INFO  | locator read: DataLocator(24b43f6a, 2283) | org.apache.activemq.leveldb.LevelDBClient
| main 
> 2014-01-17 14:44:19,118 | INFO  | Seq read: 260221 | org.apache.activemq.leveldb.LevelDBClient
| main 
> 2014-01-17 14:44:19,118 | INFO  | locator read: DataLocator(24b4487e, 2283) | org.apache.activemq.leveldb.LevelDBClient
| main 
> 2014-01-17 14:44:19,118 | INFO  | Seq read: 260222 | org.apache.activemq.leveldb.LevelDBClient
| main 
> 2014-01-17 14:44:19,118 | INFO  | locator read: DataLocator(24b451a4, 2283) | org.apache.activemq.leveldb.LevelDBClient
| main 
> 2014-01-17 14:44:19,124 | INFO  | No IOExceptionHandler registered, ignoring IO exception
| org.apache.activemq.broker.BrokerService | LevelDB IOException handler. 
> java.io.EOFException: File '/solidstate/ldbkp/000000001f4022e4.log' offset: 91500234

>         at org.apache.activemq.leveldb.RecordLog$LogReader.read(RecordLog.scala:299)

>         at org.apache.activemq.leveldb.RecordLog$$anonfun$read$2.apply(RecordLog.scala:564)

>         at org.apache.activemq.leveldb.RecordLog$$anonfun$read$2.apply(RecordLog.scala:564)

>         at org.apache.activemq.leveldb.RecordLog.get_reader(RecordLog.scala:554) 
>         at org.apache.activemq.leveldb.RecordLog.read(RecordLog.scala:564) 
>         at org.apache.activemq.leveldb.LevelDBClient.getMessage(LevelDBClient.scala:1318)

>         at org.apache.activemq.leveldb.LevelDBClient$$anonfun$queueCursor$1.apply(LevelDBClient.scala:1257)

>         at org.apache.activemq.leveldb.LevelDBClient$$anonfun$queueCursor$1.apply(LevelDBClient.scala:1252)

>         at org.apache.activemq.leveldb.LevelDBClient$$anonfun$collectionCursor$1$$anonfun$apply$mcV$sp$12.apply(LevelDBClient.scala:1342)

>         at org.apache.activemq.leveldb.LevelDBClient$$anonfun$collectionCursor$1$$anonfun$apply$mcV$sp$12.apply(LevelDBClient.scala:1341)

>         at org.apache.activemq.leveldb.LevelDBClient$RichDB.check$4(LevelDBClient.scala:323)

>         at org.apache.activemq.leveldb.LevelDBClient$RichDB.cursorRange(LevelDBClient.scala:325)

>         at org.apache.activemq.leveldb.LevelDBClient$$anonfun$collectionCursor$1.apply$mcV$sp(LevelDBClient.scala:1341)

>         at org.apache.activemq.leveldb.LevelDBClient$$anonfun$collectionCursor$1.apply(LevelDBClient.scala:1341)

>         at org.apache.activemq.leveldb.LevelDBClient$$anonfun$collectionCursor$1.apply(LevelDBClient.scala:1341)

>         at org.apache.activemq.leveldb.LevelDBClient.usingIndex(LevelDBClient.scala:1019)

>         at org.apache.activemq.leveldb.LevelDBClient$$anonfun$might_fail_using_index$1.apply(LevelDBClient.scala:1025)

>         at org.apache.activemq.leveldb.LevelDBClient.might_fail(LevelDBClient.scala:549)

>         at org.apache.activemq.leveldb.LevelDBClient.might_fail_using_index(LevelDBClient.scala:1025)

>         at org.apache.activemq.leveldb.LevelDBClient.collectionCursor(LevelDBClient.scala:1340)

>         at org.apache.activemq.leveldb.LevelDBClient.queueCursor(LevelDBClient.scala:1252)

>         at org.apache.activemq.leveldb.DBManager.cursorMessages(DBManager.scala:713)

>         at org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore.recoverNextMessages(LevelDBStore.scala:758)

>         at org.apache.activemq.broker.region.Queue.initialize(Queue.java:369) 
>         at org.apache.activemq.broker.region.DestinationFactoryImpl.createDestination(DestinationFactoryImpl.java:87)

>         at org.apache.activemq.broker.region.AbstractRegion.createDestination(AbstractRegion.java:516)

>         at org.apache.activemq.broker.jmx.ManagedQueueRegion.createDestination(ManagedQueueRegion.java:56)

>         at org.apache.activemq.broker.region.AbstractRegion.addDestination(AbstractRegion.java:134)

>         at org.apache.activemq.broker.region.RegionBroker.addDestination(RegionBroker.java:321)

>         at org.apache.activemq.broker.BrokerFilter.addDestination(BrokerFilter.java:167)

>         at org.apache.activemq.advisory.AdvisoryBroker.addDestination(AdvisoryBroker.java:169)

>         at org.apache.activemq.broker.BrokerFilter.addDestination(BrokerFilter.java:167)

>         at org.apache.activemq.broker.BrokerFilter.addDestination(BrokerFilter.java:167)

>   at org.apache.activemq.broker.MutableBrokerFilter.addDestination(MutableBrokerFilter.java:172)

>         at org.apache.activemq.broker.region.AbstractRegion.start(AbstractRegion.java:98)

>         at org.apache.activemq.broker.region.RegionBroker.start(RegionBroker.java:190)

>         at org.apache.activemq.broker.jmx.ManagedRegionBroker.start(ManagedRegionBroker.java:120)

>         at org.apache.activemq.broker.BrokerFilter.start(BrokerFilter.java:182) 
>         at org.apache.activemq.broker.BrokerFilter.start(BrokerFilter.java:182) 
>         at org.apache.activemq.broker.TransactionBroker.start(TransactionBroker.java:120)

>         at org.apache.activemq.broker.BrokerService$5.start(BrokerService.java:2150)

>         at org.apache.activemq.broker.BrokerService.doStartBroker(BrokerService.java:648)

>         at org.apache.activemq.broker.BrokerService.startBroker(BrokerService.java:632)

>         at org.apache.activemq.broker.BrokerService.start(BrokerService.java:568) 
>         at org.apache.activemq.xbean.XBeanBrokerService.afterPropertiesSet(XBeanBrokerService.java:73)

>         at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) 
>         at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)

>         at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)

>         at java.lang.reflect.Method.invoke(Method.java:606) 
>         at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.invokeCustomInitMethod(AbstractAutowireCapableBeanFactory.java:1608)

>         at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.invokeInitMethods(AbstractAutowireCapableBeanFactory.java:1549)

>         at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.initializeBean(AbstractAutowireCapableBeanFactory.java:1479)

>         at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:521)

>         at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:458)

>         at org.springframework.beans.factory.support.AbstractBeanFactory$1.getObject(AbstractBeanFactory.java:295)

>         at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:223)

>         at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:292)

>         at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:194)

>         at org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:628)

>         at org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:932)

>         at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:479)

>   at org.apache.xbean.spring.context.ResourceXmlApplicationContext.<init>(ResourceXmlApplicationContext.java:64)

>         at org.apache.xbean.spring.context.ResourceXmlApplicationContext.<init>(ResourceXmlApplicationContext.java:52)

>         at org.apache.activemq.xbean.XBeanBrokerFactory$1.<init>(XBeanBrokerFactory.java:104)

>         at org.apache.activemq.xbean.XBeanBrokerFactory.createApplicationContext(XBeanBrokerFactory.java:104)

>         at org.apache.activemq.xbean.XBeanBrokerFactory.createBroker(XBeanBrokerFactory.java:67)

>         at org.apache.activemq.broker.BrokerFactory.createBroker(BrokerFactory.java:71)

>         at org.apache.activemq.broker.BrokerFactory.createBroker(BrokerFactory.java:54)

>         at org.apache.activemq.console.command.StartCommand.runTask(StartCommand.java:87)

>         at org.apache.activemq.console.command.AbstractCommand.execute(AbstractCommand.java:57)

>         at org.apache.activemq.console.command.ShellCommand.runTask(ShellCommand.java:150)

>         at org.apache.activemq.console.command.AbstractCommand.execute(AbstractCommand.java:57)

>         at org.apache.activemq.console.command.ShellCommand.main(ShellCommand.java:104)

>         at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) 
>         at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)

>         at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)

>         at java.lang.reflect.Method.invoke(Method.java:606) 
>         at org.apache.activemq.console.Main.runTaskClass(Main.java:262) 
>         at org.apache.activemq.console.Main.main(Main.java:115) 
> 2014-01-17 14:44:19,156 | INFO  | Stopped LevelDB[/solidstate/ldbkp] | org.apache.activemq.leveldb.LevelDBStore
| LevelDB IOException handler. 



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

Mime
View raw message