[
https://issues.apache.org/jira/browse/BEAM-13452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17549784#comment-17549784
]
Danny McCormick commented on BEAM-13452:
----------------------------------------
This issue has been migrated to https://github.com/apache/beam/issues/21357
> 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.7#820007)
