Jingsong Lee created BEAM-2487: ---------------------------------- Summary: Give a option to ignore the timer that is larger than END_OF_GLOBAL_WINDOW Key: BEAM-2487 URL: https://issues.apache.org/jira/browse/BEAM-2487 Project: Beam Issue Type: Improvement Components: runner-flink Reporter: Jingsong Lee
Event time can not reach END_OF_GLOBAL_WINDOW in unbounded world. (Except for testing) But Flink runner will set some timers when user set a StatefulPardo/GBK with GlobalWindow. Flink maintains timers in PriorityQueue on the Java Heap. There is a bad performance when the number of keys is very much. -- This message was sent by Atlassian JIRA (v6.4.14#64029)