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
Post a Comment