i have simple storm bolt takes input kafka spout , should write standard output. extends baserichbolt. 2 pertinent methods are:
public void prepare(map stormconfig, topologycontext context, outputcollector collector) { collector_ = collector; logger_.info("testechobolt prepared."); system.out.println("testechobolt prepared."); } public void execute(tuple input) { logger_.info(input.getfields().tostring()); system.out.println(input.getfields().tostring()); collector_.ack(input); } it's wired this:
builder_ = new topologybuilder(); builder_.setspout("kafka-spout",kafkaspout,1); builder_.setbolt("echo-bolt",echobolt) .shufflegrouping("kafka-spout"); i see output constructor when submit topology cluster running on local machine, never see output bolt. storm ui shows tuples being emitted, executed, , acked, no errors.
where's output?
(this storm 0.9.5 , kafka 0.8.2.1.)
matthias had correct answer in comments. output goes $storm_home/logs unless storm.log.dir property set in $storm_home/conf/storm.yaml.
the output in .../logs/worker-*.log files.
Comments
Post a Comment