Hi! Please see discussion on https://issues.apache.org/jira/browse/BEAM-849 . A pipeline terminates when all watermarks reach infinity - regardless of boundedness.
On Wed, Mar 29, 2017 at 4:54 PM Shen Li <cs.she...@gmail.com> wrote: > Hi, > > For pipelines with unbounded sources, should waitUntilFinish() block > forever, or should it just block until the job is submitted to the cluster? > > Thanks, > > Shen >
