[
https://issues.apache.org/jira/browse/BEAM-13452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kenneth Knowles updated BEAM-13452:
-----------------------------------
Issue Type: Improvement (was: New Feature)
> Optimize Flink runner timer and OnWindowExpiration
> --------------------------------------------------
>
> Key: BEAM-13452
> URL: https://issues.apache.org/jira/browse/BEAM-13452
> Project: Beam
> Issue Type: Improvement
> Components: runner-flink
> Reporter: Reuven Lax
> Priority: P2
>
> Currently Flink batch needs to load all keys in memory to expire timers and
> call OnWindowExpiration. We could instead use the mechanism used by
> RequiresTimeSortedInput
> ([https://github.com/apache/beam/blob/v2.34.0/runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkBatchTransformTranslators.java#L702])
> to expire as we go.
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
