[STORM-2183] BaseStatefulBoltExecutor does not handle cyclic graphs

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Abandoned
• Affects Version/s: 1.x
• Component/s: storm-core
• Labels: State cyclic
• Environment: Java 1.8
• Flags: Important
• Assignee: Unassigned
• Reporter: Bill Sobel
• Created: 02/Nov/16 00:27
• Updated: 02/Jul/24 09:54
• Resolved: 02/Jul/24 09:54

Description

BaseStatefulBoltExecutor::getCheckpointInputTaskCount() returns the number of sources that a state transaction must wait for to process a transaction. In a graph where there is a loop (e.g. A->B->C->D->C) components 'C' and 'D' the required number of tuples can will never be received. The function shouldProcessTransaction will never receive the correct number of tuples, because the set required to come back form 'D' to 'C' will never be forwarded from 'C' to 'D' to begin with.

Bolt 'C' and 'D' never finish the state initialization step and as such will never pass tuples to their wrapped bolt.