[jira] [Updated] (BEAM-2398) Increasing latency within DirectRunner caused by cumulated TransformWatermarks

2017-06-01 Thread Antony Mayi (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-2398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Antony Mayi updated BEAM-2398: -- Description: Over the time the end-to-end latency of a pipeline running on DirectRunner is

[jira] [Updated] (BEAM-2398) Increasing latency within DirectRunner caused by cumulated TransformWatermarks

2017-06-01 Thread Antony Mayi (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-2398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Antony Mayi updated BEAM-2398: -- Attachment: LatencyTest.java > Increasing latency within DirectRunner caused by cumulated