Hi,
I am using
storm-kestrel 0.7.2-SNAPSHOT
storm 0.8.2
and zookeeper 3.3.3
I am getting the following exception when I run on a single machine cluster.
2013-11-25 23:46:55 executor [INFO] Processing received message source: __system:-1, stream: __tick, id: {}, [30]
2013-11-25 23:47:03 KestrelThriftSpout [INFO] Attempting reconnect to kestrel localhost:2229
2013-11-25 23:47:04 KestrelThriftSpout [WARN] Failed to read from Kestrel at localhost:2229
org.apache.thrift7.TApplicationException: Internal error processing get: 'java.lang.NullPointerException'
at org.apache.thrift7.TApplicationException.read(TApplicationException.java:108)
at org.apache.thrift7.TServiceClient.receiveBase(TServiceClient.java:71)
at net.lag.kestrel.thrift.Kestrel$Client.recv_get(Kestrel.java:134)
at net.lag.kestrel.thrift.Kestrel$Client.get(Kestrel.java:118)
at backtype.storm.spout.KestrelThriftClient.get(KestrelThriftClient.java:65)
at backtype.storm.spout.KestrelThriftSpout.bufferKestrelGet(KestrelThriftSpout.java:160)
at backtype.storm.spout.KestrelThriftSpout.tryEachKestrelUntilBufferFilled(KestrelThriftSpout.java:186)
at backtype.storm.spout.KestrelThriftSpout.nextTuple(KestrelThriftSpout.java:195)
at backtype.storm.daemon.executor$fn__3985$fn__3997$fn__4026.invoke(executor.clj:502)
at backtype.storm.util$async_loop$fn__465.invoke(util.clj:377)
at clojure.lang.AFn.run(AFn.java:24)
at java.lang.Thread.run(Thread.java:679)