Trident not working on streaming spout

[Chen Wang]

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