activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kal123 <kpfininf...@gmail.com>
Subject ReplicatedLevelDb failover giving error Unknown data type: -58
Date Mon, 11 Nov 2013 22:06:53 GMT
What would cause this unknown data type error -58?  Looks like
replicatedleveldb is reading msg from disk (using activemq 5.9).

2013-11-11 16:42:42,625 | INFO  | Slave has now caught up:
e2a40b80-1fee-4d13-a94d-521c05bb0130 |
org.apache.activemq.leveldb.replicated.MasterLevelDBStore |
hawtdispatch-DEFAULT-3
2013-11-11 16:43:12,234 | INFO  | Stopping BrokerService[largeamq] due to
exception, java.io.IOException: Unknown data type: -58 |
org.apache.activemq.util.DefaultIOExceptionHandler | LevelDB IOException
handler.
java.io.IOException: Unknown data type: -58
        at
org.apache.activemq.openwire.OpenWireFormat.looseUnmarshalNestedObject(OpenWireFormat.java:477)
        at
org.apache.activemq.openwire.v6.BaseDataStreamMarshaller.looseUnmarsalCachedObject(BaseDataStreamMarshaller.java:488)
        at
org.apache.activemq.openwire.v6.RemoveSubscriptionInfoMarshaller.looseUnmarshal(RemoveSubscriptionInfoMarshaller.java:119)
        at
org.apache.activemq.openwire.OpenWireFormat.doUnmarshal(OpenWireFormat.java:373)
        at
org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:210)
        at
org.apache.activemq.leveldb.LevelDBClient.decodeMessage(LevelDBClient.scala:1261)
        at
org.apache.activemq.leveldb.LevelDBClient$$anonfun$getMessage$1.apply(LevelDBClient.scala:1252)
        at
org.apache.activemq.leveldb.LevelDBClient$$anonfun$getMessage$1.apply(LevelDBClient.scala:1252)
        at scala.Option.map(Option.scala:133)
        at
org.apache.activemq.leveldb.LevelDBClient.getMessage(LevelDBClient.scala:1252)
        at
org.apache.activemq.leveldb.LevelDBClient$$anonfun$queueCursor$1.apply(LevelDBClient.scala:1197)
        at
org.apache.activemq.leveldb.LevelDBClient$$anonfun$queueCursor$1.apply(LevelDBClient.scala:1194)
        at
org.apache.activemq.leveldb.LevelDBClient$$anonfun$collectionCursor$1$$anonfun$apply$mcV$sp$12.apply(LevelDBClient.scala:1272)
        at
org.apache.activemq.leveldb.LevelDBClient$$anonfun$collectionCursor$1$$anonfun$apply$mcV$sp$12.apply(LevelDBClient.scala:1271)
        at
org.apache.activemq.leveldb.LevelDBClient$RichDB.check$4(LevelDBClient.scala:315)
        at
org.apache.activemq.leveldb.LevelDBClient$RichDB.cursorRange(LevelDBClient.scala:317)
        at
org.apache.activemq.leveldb.LevelDBClient$$anonfun$collectionCursor$1.apply$mcV$sp(LevelDBClient.scala:1271)
        at
org.apache.activemq.leveldb.LevelDBClient$$anonfun$collectionCursor$1.apply(LevelDBClient.scala:1271)
        at
org.apache.activemq.leveldb.LevelDBClient$$anonfun$collectionCursor$1.apply(LevelDBClient.scala:1271)
        at
org.apache.activemq.leveldb.LevelDBClient.usingIndex(LevelDBClient.scala:968)
        at
org.apache.activemq.leveldb.LevelDBClient$$anonfun$might_fail_using_index$1.apply(LevelDBClient.scala:974)
        at
org.apache.activemq.leveldb.LevelDBClient.might_fail(LevelDBClient.scala:540)
        at
org.apache.activemq.leveldb.LevelDBClient.might_fail_using_index(LevelDBClient.scala:974)
        at
org.apache.activemq.leveldb.LevelDBClient.collectionCursor(LevelDBClient.scala:1270)
        at
org.apache.activemq.leveldb.LevelDBClient.queueCursor(LevelDBClient.scala:1194)
        at
org.apache.activemq.leveldb.DBManager.cursorMessages(DBManager.scala:708)
        at
org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore.recoverNextMessages(LevelDBStore.scala:741)
        at
org.apache.activemq.broker.region.cursors.QueueStorePrefetch.doFillBatch(QueueStorePrefetch.java:106)
        at
org.apache.activemq.broker.region.cursors.AbstractStoreCursor.fillBatch(AbstractStoreCursor.java:258)
        at
org.apache.activemq.broker.region.cursors.AbstractStoreCursor.hasNext(AbstractStoreCursor.java:145)
        at
org.apache.activemq.broker.region.cursors.StoreQueueCursor.hasNext(StoreQueueCursor.java:131)
        at
org.apache.activemq.broker.region.Queue.doPageInForDispatch(Queue.java:1876)
        at
org.apache.activemq.broker.region.Queue.pageInMessages(Queue.java:2086)




--
View this message in context: http://activemq.2283324.n4.nabble.com/ReplicatedLevelDb-failover-giving-error-Unknown-data-type-58-tp4674186.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Mime
View raw message