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

["Roman Khachatryan (Jira)" <ji...@apache.org>]

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)