Re: how to ensure storm not write message twice to local file

[jinhong lu]

Thanks Javier,
    I want to built the topo like this:
    read message from kafka—> grep —>persist the grep result to hdfs/base 
through Opaque state.
    And then another stream(by drpc) to read message from hdfs/hbase, since the 
Opaque transaction keeps the pre state and current state, I can read message 
from the pre state.

   Is it work? thanks.


> 在 2015年7月4日，02:21，Javier Gonzalez <jagon...@gmail.com> 写道：
> 
> Javier