> 1- Does scaling up/down using rebalance will maintain the state in case of > stateful task proposed in storm 1.0.2.
The current rebalance and state logic takes care of this. However, if we do dynamic task scaling in future, the state migration also needs to be taken care of. Thanks, Arun From: anshu shukla <anshushuk...@gmail.com> Reply-To: "user@storm.apache.org" <user@storm.apache.org> Date: Monday, February 13, 2017 at 5:02 PM To: "user@storm.apache.org" <user@storm.apache.org> Subject: Fault tolerance for stateful operator Hello , 1- Does scaling up/down using rebalance will maintain the state in case of stateful task proposed in storm 1.0.2. http://storm.apache.org/releases/2.0.0-SNAPSHOT/State-checkpointing.html 2- Is there anyway already in storm to monitor throughput on each bolt .(e.g. any readily available metrics consumer that gives the emitted messages values on UI) -- Thanks & Regards, Anshu Shukla