Zakelly Lan created FLINK-36949:
-----------------------------------

             Summary: Make getCurrentKey of async state operators return the 
ground truth
                 Key: FLINK-36949
                 URL: https://issues.apache.org/jira/browse/FLINK-36949
             Project: Flink
          Issue Type: Sub-task
          Components: Runtime / Async State Processing
            Reporter: Zakelly Lan
            Assignee: Zakelly Lan


Currently, the abstract operators will cache the current context, and the 
`getCurrentKey()` will return the key of this context. However, this context 
may not be the context of current processing callback. It is for the 
convenience of releasing record reference counting. We should fix that in case 
some user logic may call `getCurrentKey()`.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to