What interface does your spout implement? Is it IBatchSpout?
On Mon, Feb 17, 2014 at 8:49 PM, Chen Wang <[email protected]>wrote: > Hi, > I might be missing something apparent. In my spout, next tuple method, I > have an infinite loop to read from our socket server: > > @Override > > public void nextTuple() { > > try { > > String line; > > while ((line = socket.readLine()) != null) { > > System.out.println("emitting new entries"); > > _collector.emit(new Values(line)); > > } > > } catch (Exception e) { > > // TODO > > // log the exception with Storm > > } > > } > > > Then in my trident topology, i am doing something like:(psedu code) > > topology.newStream( > > myspout). > > each(filter logic) > > .groupBy( mykey) > > .persistentAggregate( > > > When I run it in local mode, it seems that the trident will not catch any > tuple emitted from my spout. The topology will just spin on the spout > emitting tuples, while the rest of the topology never get executed. How > would I fix that? > > > Using normal bolt/topology will be able to receive the tuple. > > Thanks, > > Chen > -- Danijel Schiavuzzi
