Roman Khachatryan created FLINK-26063:
-----------------------------------------
Summary: [Changelog] Incorrect key group logged for PQ.poll and
remove
Key: FLINK-26063
URL: https://issues.apache.org/jira/browse/FLINK-26063
Project: Flink
Issue Type: Bug
Components: Runtime / State Backends
Affects Versions: 1.15.0
Reporter: Roman Khachatryan
Assignee: Roman Khachatryan
Fix For: 1.15.0
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]
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
