I’m trying to send data through Tranquility as a BeamBolt in Storm cluster. I think I’ve got it almost working where it creates the realtime task but it doesn’t send data to it. I don’t see any error in task log nor in Tranquility log. The only error I can see is that in the zookeeper it has the following error(?) :
2015-03-05 21:56:32,247 [myid:] - INFO [ProcessThread(sid:0 cport:-1)::PrepRequestProcessor@645] - Got user-level KeeperException when processing sessionid:0x14be1e105e700f3 type:create cxid:0x24 zxid:0xdf1 txntype:-1 reqpath:n/a Error Path:/prod/discovery/druid_traffic_test11-21-0000-0000 Error:KeeperErrorCode = NoNode for /prod/discovery/druid_traffic_test11-21-0000-0000
I have a very simple storm topology where I just have a kafka spout to feed tsv data and a data mapping bolt that translates tsv data into HashMap and a tranquility beam bolt to send to Druid. I run in storm local mode and I don’t see any error from tranquility log but the real time task doesn’t get any data at all. I see ClusteredBeam flushes messages in the log but I don’t see any “sending”.
Can anybody help me find where I need to dig in to make this work?
Here is my setup :
Druid cluster version : 0.6.160