[
https://issues.apache.org/jira/browse/BEAM-7520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16907502#comment-16907502
]
Kenneth Knowles commented on BEAM-7520:
---
... and that new timer will be committed as
[
https://issues.apache.org/jira/browse/BEAM-7520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16907497#comment-16907497
]
Jan Lukavský commented on BEAM-7520:
Actually, the issue is that DirectRunner does the
[
https://issues.apache.org/jira/browse/BEAM-7520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16907424#comment-16907424
]
Kenneth Knowles commented on BEAM-7520:
---
Nice catch. A priority queue of timers shou
[
https://issues.apache.org/jira/browse/BEAM-7520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16873347#comment-16873347
]
Jan Lukavský commented on BEAM-7520:
Alternative solution discussed in:
https://lists
[
https://issues.apache.org/jira/browse/BEAM-7520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16865594#comment-16865594
]
Jan Lukavský commented on BEAM-7520:
PR rebased, fixed tests for validatesRunner, all
[
https://issues.apache.org/jira/browse/BEAM-7520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16860945#comment-16860945
]
Jan Lukavský commented on BEAM-7520:
The fix is in that timers are fired for single In
[
https://issues.apache.org/jira/browse/BEAM-7520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16860942#comment-16860942
]
Jan Lukavský commented on BEAM-7520:
PR: https://github.com/apache/beam/pull/8815
> D
[
https://issues.apache.org/jira/browse/BEAM-7520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16859960#comment-16859960
]
Jan Lukavský commented on BEAM-7520:
I have experimented with this a little and have n
