Correct. On Wed, Mar 29, 2017, 5:35 PM Shen Li <cs.she...@gmail.com> wrote:
> Hi, thanks for the prompt reply. I read the discussion. So, the > waitUntilFinish() should *block* until all watermarks reach infinity > regardless of how long (1 second, 1 year, 100 years) it might take, right? > > Shen > > On Wed, Mar 29, 2017 at 8:00 PM, Eugene Kirpichov < > kirpic...@google.com.invalid> wrote: > > > 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 > > > > > >
