[FLINK-31017] Early-started partial match timeout not yield completed matches

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.16.0
• Fix Version/s: 1.17.0, 1.16.2
• Component/s: Library / CEP
• Labels: pull-request-available
• Assignee: Juntao Hu
• Reporter: Juntao Hu
• Created: 10/Feb/23 14:35
• Updated: 17/Feb/23 08:29
• Resolved: 17/Feb/23 08:28

Description

Pattern example:

Pattern.begin("A").where(startsWith("a")).oneOrMore().consecutive().greedy()
    .followedBy("B")
    .where(count("A") > 2 ? startsWith("b") : startsWith("c"))
    .within(Time.seconds(3));

Sequence example, currently without any output:

a1 a2 a3 a4 c1

When match[a3, a4, c1] completes, partial match[a1, a2, a3, a4] is earlier, so NFA#processMatchesAccordingToSkipStrategy() won't give any result, which is the expected behavior. However, when partial match[a1, a2, a3, a4] is timed-out, completed match[a3, a4, c1] should be "freed" from NFAState to output.

Issue Links

• links to: GitHub Pull Request #21920