GitHub user bharathkk opened a pull request:
https://github.com/apache/samza/pull/503
SAMZA-1653: Support waitForFinish in remote application runner and add
waitForFinish
Added the following APIs to AbstractApplicationRunner
`void waitForFinish()`
`void waitForFinish(Duration timeout)`
Implemented the wait for finish methods in remote application runner. Note
currently, there is disparity in the APIs in terms of associating runners with
stream application. Ideally, we want to decide on the cardinal relation between
them and change the APIs accordingly.
The goal of the PR is limited to introduce API (waitForFinish) parity
between runners in the current setup.
@xinyuiscool
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/bharathkk/samza samza-1653
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/samza/pull/503.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #503
----
commit b8c3129054cf3f3adcac2d5196e46e3ecac31ee9
Author: Bharath Kumarasubramanian <bkumaras@...>
Date: 2018-04-30T16:22:39Z
Support waitForFinish in remote application runner and add waitForFinish
with duration
----
---
