apache / apache/beam

When triggers are changed via pipeline update, stale finished triggers data applied

Open
#17,965 0 comments 0 reactions 0 assignees View on GitHub
bug dataflow P3 runners
Dominant language
Java
Stars
8.7k
Forks
4.7k
Avg merge
1d 20h
Merged PRs (30d)
196

Description

TriggerRunner tracks which trigger subexpresions are finished. When the trigger expession is updated via pipeline update, this data is applied arbitrarily to the new trigger expression.

Implementation note: trigger subexpressions are identified by number, and their finished state stored in a bit set.

Imported from Jira [BEAM-31](https://issues.apache.org/jira/browse/BEAM-31). Original Jira may contain additional context.
Reported by: kenn.

Contributor guide

Open the contributing guide

Research direction

Start by locating TriggerRunner and the pipeline-update path that replaces trigger expressions. Inspect how trigger subexpressions are numbered and how their finished state is restored from the bit set. Done means finished state from the old expression is not applied arbitrarily to the updated expression, with behavior verified by appropriate regression coverage.

Written by the indexing model from the issue text.

Assessment

Tech stack
java
Domain
stream-processing
Issue type
Bug
Difficulty
4/5
Estimated time
3-5 days
Activity status
Stale
Clarity
Needs clarification
Newbie friendliness
30/100

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.