When debuggin the exclamationTopology example the tuple.messageId.hashCode() seems to be alway Zero. Is this because I'm running it in the local test cluster?

Is the tuple.messageId.hashCode() unique for each tuple? Because 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)

Thats why i was wondering why the hashCode was zero.

Reply via email to