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 > > >
