I realized that storms tuple do not have a unique id inside bolt (I logged it in a cluster). The tuple.MessageId.hashCode only returns 0. Is there another way to receive the unique id?

The ShellBolt generates an extra unique id for each tuple (https://github.com/apache/incubator-storm/blob/master/storm-core/src/jvm/backtype/storm/task/ShellBolt.java#L171)

The executor seems to already create a unique id for the MessageId (https://github.com/apache/incubator-storm/blob/79f258ec6d3e85f190a7e4861ff6cefb1ce905f4/storm-core/src/clj/backtype/storm/daemon/executor.clj#L424)

Am I doing something wrong?

Reply via email to