Hi Abhishek,
Right now delete/clear is not supported, so you need to workaround this by putting ‘null’ values. Clear/delete will be added in future. There’s a pending patch to support delete (https://github.com/apache/storm/pull/1470). Thanks, Arun From: Abhishek Raj <abhishek....@saavn.com> Reply-To: "user@storm.apache.org" <user@storm.apache.org> Date: Thursday, November 3, 2016 at 8:12 PM To: "user@storm.apache.org" <user@storm.apache.org> Subject: Stateful bolts Hi. I was looking into state management which looks like a really cool feature but I am wondering if it'd be right for my use case. One of the bolts does bulk updates to database and stores the update information temporarily in hashmap. Once the update is done, the map is cleared. If the worker crashes, the update data is lost so I want to persist update information across restarts using RedisKeyValueState. I could use get/put to modify individual values in KeyValueState but the interface doesn't expose any method to clear all values in the KeyValueState. So I am wondering if state management is not the right tool here and what's the appropriate use of state management. Any insight on this would be great. Thanks. -- Abhishek