[BEAM-6650] FlinkRunner fails to checkpoint elements emitted during finishBundle - ASF JIRA

XML

Word

Printable

JSON

Details

Type: Bug
Status: Resolved
Priority: P2
Resolution: Fixed
Affects Version/s: None
Fix Version/s: 2.11.0
Component/s: runner-flink
Labels:
None

Description

Elements emitted during the finalizeBundle call in snapshopState are lost after the pipeline is restored. This only happens when the operator is keyed.

Attachments

Issue Links

links to

GitHub Pull Request #7810

GitHub Pull Request #7874

Activity

People

Assignee:: Maximilian Michels

Reporter:: Maximilian Michels

Votes:: 0 Vote for this issue

Watchers:: 3 Start watching this issue

Dates

Created:: 11/Feb/19 20:11

Updated:: 16/May/20 13:36

Resolved:: 20/Feb/19 21:40

Time Tracking

Estimated:

Not Specified

Remaining:

Logged:

6h 20m