But suppose I want to replay value in the tuple to the older taskID or
StreamID etc. all those details will be lost . (I am doing this for
replaying tuples after state migration.)
On Tue, Mar 21, 2017 at 9:31 AM, Arun Mahadevan wrote:
> Storm uses Kryo to serialize Tuples.
Why don’t you rely on storm’s replay mechanisms to have the tuple replayed? Are
you trying to handle the state once the number of tasks are increased? The
replayed tuples can go to the new tasks as long as the state is migrated
correctly.
I don’t fully get what you are trying to do. Maybe
Hello,
I am new storm user. I am trying to set up storm on my windows 7 64 bit
machine.
I am getting this error on storm ui
org.apache.storm.utils.NimbusLeaderNotFoundException:
Could not find leader nimbus from seed hosts [localhost]
and this thing in nimbus logs-->