[FLINK-26063] [Changelog] Incorrect key group logged for PQ.poll and remove

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.15.0
• Fix Version/s: 1.15.0, 1.16.0
• Component/s: Runtime / State Backends
• Labels: pull-request-available
• Assignee: Roman Khachatryan
• Reporter: Roman Khachatryan
• Created: 09/Feb/22 19:49
• Updated: 14/Jul/22 23:11
• Resolved: 15/Mar/22 17:14

Description

Key group is logged so that state changes can be re-distributed or shuffled.
It is currently obtained from keyContext during poll() and remove() operations.
However, keyContext is not updated when dequeing processing time timers.

The impact is relatively small for remove(): in the worst case, the operation will be ignored.
poll() should probably be replaced with remove() anyways - see FLINK-26062.

One way to solve this problem is to extract key group from the polled element - if it is a timer.

cc: masteryhx, ym, yunta

Issue Links

• Testing discovered: FLINK-25144 Test Changelog State Backend manually
• links to: GitHub Pull Request #19051
• links to: GitHub Pull Request #19096