You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@activemq.apache.org by "Anuj Khandelwal (JIRA)" <ji...@apache.org> on 2015/07/17 12:22:04 UTC

[jira] [Created] (AMQ-5894) NPE in replicated levelDB

Anuj Khandelwal created AMQ-5894:
------------------------------------

             Summary: NPE in replicated levelDB
                 Key: AMQ-5894
                 URL: https://issues.apache.org/jira/browse/AMQ-5894
             Project: ActiveMQ
          Issue Type: Bug
          Components: activemq-leveldb-store, Broker
    Affects Versions: 5.11.1
            Reporter: Anuj Khandelwal


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



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)