[FLINK-24310] A bug in the BufferingSink example in the doc

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.14.0, 1.13.3, 1.15.0
• Fix Version/s: 1.13.6, 1.14.3, 1.15.0
• Component/s: Documentation
• Labels: pull-request-available stale-assigned
• Assignee: Jun Qin
• Reporter: Jun Qin
• Created: 16/Sep/21 08:54
• Updated: 15/Dec/21 01:44
• Resolved: 29/Nov/21 11:04

Description

The following line in the BufferingSink on this page has a bug:

if (bufferedElements.size() == threshold) {

It should be >= instead of == , because when restoring from a checkpoint during downscaling, the task may get more elements than the threshold. 

Issue Links

• links to: GitHub Pull Request #17299
• links to: GitHub Pull Request #17300
• links to: GitHub Pull Request #17596