No output from Storm bolt -


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