[ https://issues.apache.org/jira/browse/BEAM-604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15449366#comment-15449366 ]
Luke Cwik commented on BEAM-604: -------------------------------- Would be better if the Dataflow service just shutdown jobs that hit max watermark automatically. > Use Watermark Check Streaming Job Finish in TestDataflowRunner > --------------------------------------------------------------- > > Key: BEAM-604 > URL: https://issues.apache.org/jira/browse/BEAM-604 > Project: Beam > Issue Type: Bug > Reporter: Mark Liu > Assignee: Mark Liu > > Currently, streaming job with bounded input can't be terminated automatically > and TestDataflowRunner can't handle this case. Need to update > TestDataflowRunner so that streaming integration test such as > WindowedWordCountIT can run with it. > Implementation: > Query watermark of each step and wait until all watermarks set to MAX then > cancel the job. -- This message was sent by Atlassian JIRA (v6.3.4#6332)