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

'hasOwnProperty' in javascript -

python - ValueError: No axis named 1 for object type <class 'pandas.core.series.Series'> -

java - How to provide dependency injections in Eclipse RCP 3.x? -