Hi,
We are getting below exception when we are trying to start slave broker in
replicated leveldb. Broker was able to come up and run properly. But I am
not sure why this exception was thrown here:
java.lang.RuntimeException: An IOException was thrown (should never happen
in this method).
at
org.apache.activemq.leveldb.record.CollectionKey$Buffer.bean(CollectionKey.java:264)
at
org.apache.activemq.leveldb.record.CollectionKey$Buffer.getKey(CollectionKey.java:284)
at
org.apache.activemq.leveldb.LevelDBClient$$anonfun$replay_from$1$$anonfun$apply$mcV$sp$4.apply(LevelDBClient.scala:757)
at
org.apache.activemq.leveldb.LevelDBClient$$anonfun$replay_from$1$$anonfun$apply$mcV$sp$4.apply(LevelDBClient.scala:740)
at scala.Option.map(Option.scala:145)
at
org.apache.activemq.leveldb.LevelDBClient$$anonfun$replay_from$1.apply$mcV$sp(LevelDBClient.scala:740)
at
org.apache.activemq.leveldb.LevelDBClient$$anonfun$replay_from$1.apply(LevelDBClient.scala:707)
at
org.apache.activemq.leveldb.LevelDBClient$$anonfun$replay_from$1.apply(LevelDBClient.scala:707)
at
org.apache.activemq.leveldb.LevelDBClient.might_fail(LevelDBClient.scala:549)
at
org.apache.activemq.leveldb.LevelDBClient.replay_from(LevelDBClient.scala:706)
at
org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$send_wal_ack$1.apply$mcV$sp(SlaveLevelDBStore.scala:185)
at
org.fusesource.hawtdispatch.package$$anon$4.run(hawtdispatch.scala:330)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.io.EOFException
at
org.fusesource.hawtbuf.proto.CodedInputStream.readRawByte(CodedInputStream.java:346)
at
org.fusesource.hawtbuf.proto.CodedInputStream.readRawVarint32(CodedInputStream.java:240)
at
org.fusesource.hawtbuf.proto.CodedInputStream.readInt32(CodedInputStream.java:169)
at
org.fusesource.hawtbuf.proto.CodedInputStream.skipField(CodedInputStream.java:111)
at
org.apache.activemq.leveldb.record.CollectionKey$Bean.mergeUnframed(CollectionKey.java:172)
at
org.apache.activemq.leveldb.record.CollectionKey$Buffer.bean(CollectionKey.java:259)
... 14 more
Thanks,
Anuj
--
View this message in context:
http://activemq.2283324.n4.nabble.com/An-IOException-was-thrown-while-starting-slave-broker-tp4700041.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
