Exceptions in leveldb replication

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

Exceptions in leveldb replication

khandelwalanuj
This post has NOT been accepted by the mailing list yet.
Hi,

I was using replicated leveldb configuration :

I am running two brokers: one as master and other as slave.

<amq:replicatedLevelDB
directory="/var/tmp/leveldb/"
replicas="1"
bind="tcp://0.0.0.0:0"
zkAddress="zk1,zk2,zk3"
sync="quorum_disk"
zkPath="/u/khandela"
/>


Observed this error in slave broker logs. What can cause this? and how can I avoid it?

java.lang.RuntimeException: org.fusesource.hawtbuf.proto.InvalidProtocolBufferException: Protocol message end-group tag did not match expected tag.
        at org.apache.activemq.leveldb.record.CollectionKey$Buffer.bean(CollectionKey.java:262)
        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: org.fusesource.hawtbuf.proto.InvalidProtocolBufferException: Protocol message end-group tag did not match expected tag.
        at org.fusesource.hawtbuf.proto.InvalidProtocolBufferException.invalidEndTag(InvalidProtocolBufferException.java:62)
        at org.fusesource.hawtbuf.proto.CodedInputStream.checkLastTagWas(CodedInputStream.java:98)
        at org.fusesource.hawtbuf.proto.CodedInputStream.skipField(CodedInputStream.java:121)
        at org.apache.activemq.leveldb.record.CollectionKey$Bean.mergeUnframed(CollectionKey.java:172)
        at org.apache.activemq.leveldb.record.CollectionKey$Buffer.bean(CollectionKey.java:259)


Thanks,
Anuj