apache - Field grouping in case worker dies in Storm -


i have use case using local cache maintain counters ids. did fieldsgrouping("spout", new fields("id")) in topology class. let's id1 getting processed in processingbolt on worker1 , id2 getting processed in processingbolt on worker2. if worker2 dies , id2 start getting processed on worker1 ?

yes. storm used abstraction of tasks internally. if use fieldsgrouping, each id mapped task, , task executed bolt instances.

if 1 bold instance fails, storm move task other bolt instances.


Comments

Popular posts from this blog

javascript - Knockout pushing observable and computed data to an observable array -

'hasOwnProperty' in javascript -

Trouble making a JSON string -