Github user roshannaik commented on a diff in the pull request:
    --- Diff: 
    @@ -22,19 +22,23 @@
     import org.apache.storm.executor.TupleInfo;
     import org.apache.storm.spout.ISpout;
     import org.apache.storm.spout.ISpoutOutputCollector;
    +import org.apache.storm.tuple.AddressedTuple;
     import org.apache.storm.tuple.MessageId;
     import org.apache.storm.tuple.TupleImpl;
     import org.apache.storm.tuple.Values;
    -import org.apache.storm.utils.Utils;
     import org.apache.storm.utils.MutableLong;
     import org.apache.storm.utils.RotatingMap;
    +import org.apache.storm.utils.Utils;
    +import org.slf4j.Logger;
    +import org.slf4j.LoggerFactory;
     import java.util.ArrayList;
     import java.util.List;
     import java.util.Random;
    +// Methods are not thread safe. Each thread expected to have a separate 
instance, or else synchronize externally
    --- End diff --
    It is to figure out what will have for Storm 2.0... since we cannot make 
any breaking changes even if we like to thereafter until 3.0.  


Reply via email to