[ https://issues.apache.org/jira/browse/FLINK-15109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
zhijiang reassigned FLINK-15109: -------------------------------- Assignee: Roman Khachatryan > InternalTimerServiceImpl references restored state after use, taking up > resources unnecessarily > ----------------------------------------------------------------------------------------------- > > Key: FLINK-15109 > URL: https://issues.apache.org/jira/browse/FLINK-15109 > Project: Flink > Issue Type: Improvement > Components: Runtime / Task > Affects Versions: 1.9.1 > Reporter: Roman Khachatryan > Assignee: Roman Khachatryan > Priority: Trivial > Labels: pull-request-available > Time Spent: 20m > Remaining Estimate: 0h > > E.g. > org.apache.flink.streaming.api.operators.InternalTimerServiceImpl#restoredTimersSnapshot: > # written in restoreTimersForKeyGroup() > # used in startTimerService() > # and then never used again. > -- This message was sent by Atlassian Jira (v8.3.4#803005)