Good noon to everyone, I have encountered problems with synchronization of component execution.
When the topology starts, the spout starts emitting tuples before the other components are prepared (the bolts recover state from redis, it takes considerable amount of time). The emitted tuples that cannot be processed are buffered in memory. fill the heap and cause premanent GC and a slow painful death for the worker process. Is it meant to be like this? In the second case, a worker running part of the topology (not the spout) dies. The spout keeps working even though it knows the other worker is dead and drops messages to it instead of waiting for it to come up again. We have solved the first one by making the spout wait until all the bolts come up, but the secondd problem would require noticeable amount of work. Are theese behaviors intended? Can they be changed? Thanks for replies in advance, Martin B
