[AMQ-5894] NPE in replicated levelDB

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Won't Fix
• Affects Version/s: 5.11.1
• Component/s: Broker, LevelDB
• Assignee: Unassigned
• Reporter: Anuj Khandelwal
• Created: 17/Jul/15 10:21
• Updated: 06/Feb/17 14:22
• Resolved: 06/Feb/17 14:22

Description

I am trying to use replicated leveldb for my use case. Below is the config I am using :

<amq:persistenceAdapter>
<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"
/>
</amq:persistenceAdapter>

I got below exception in slave broker logs (looks similar to https://issues.jboss.org/browse/ENTMQ-437 ):

Exception in thread "hawtdispatch-DEFAULT-2" java.lang.NullPointerException
at org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$wal_handler$1$$anonfun$org$apache$activemq$leveldb$replicated$SlaveLevelDBStore$$anonfun$$readData$1$1.apply$mcV$sp(SlaveLevelDBStore.scala:217)
at org.fusesource.hawtdispatch.package$$anon$4.run(hawtdispatch.scala:330)
at org.apache.activemq.leveldb.replicated.ReplicationProtocolCodec$$anon$3.apply(ReplicationProtocolCodec.scala:103)
at org.apache.activemq.leveldb.replicated.ReplicationProtocolCodec$$anon$3.apply(ReplicationProtocolCodec.scala:99)
at org.fusesource.hawtdispatch.transport.AbstractProtocolCodec.read(AbstractProtocolCodec.java:355)
at org.fusesource.hawtdispatch.transport.TcpTransport.drainInbound(TcpTransport.java:710)
at org.fusesource.hawtdispatch.transport.TcpTransport$6.run(TcpTransport.java:592)
at org.fusesource.hawtdispatch.internal.NioDispatchSource$3.run(NioDispatchSource.java:209)
at org.fusesource.hawtdispatch.internal.SerialDispatchQueue.run(SerialDispatchQueue.java:100)
at org.fusesource.hawtdispatch.internal.pool.SimpleThread.run(SimpleThread.java:77)
Exception in thread "hawtdispatch-DEFAULT-2" java.lang.NullPointerException
at org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$wal_handler$1$$anonfun$org$apache$activemq$leveldb$replicated$SlaveLevelDBStore$$anonfun$$readData$1$1.apply$mcV$sp(SlaveLevelDBStore.scala:217)
at org.fusesource.hawtdispatch.package$$anon$4.run(hawtdispatch.scala:330)
at org.apache.activemq.leveldb.replicated.ReplicationProtocolCodec$$anon$3.apply(ReplicationProtocolCodec.scala:103)
at org.apache.activemq.leveldb.replicated.ReplicationProtocolCodec$$anon$3.apply(ReplicationProtocolCodec.scala:99)
at org.fusesource.hawtdispatch.transport.AbstractProtocolCodec.read(AbstractProtocolCodec.java:355)
at org.fusesource.hawtdispatch.transport.TcpTransport.drainInbound(TcpTransport.java:710)
at org.fusesource.hawtdispatch.transport.TcpTransport$6.run(TcpTransport.java:592)
at org.fusesource.hawtdispatch.internal.NioDispatchSource$3.run(NioDispatchSource.java:209)
at org.fusesource.hawtdispatch.internal.SerialDispatchQueue.run(SerialDispatchQueue.java:100)
at org.fusesource.hawtdispatch.internal.pool.SimpleThread.run(SimpleThread.java:77

Can someone check this.

Thanks,
Anuj